-
Notifications
You must be signed in to change notification settings - Fork 472
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Added PassRegularMessagesUpDirectly policy
- Loading branch information
Showing
2 changed files
with
42 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,38 @@ | ||
package org.jgroups.util; | ||
|
||
import org.jgroups.Message; | ||
|
||
/** | ||
* {@link org.jgroups.stack.MessageProcessingPolicy} which passes regular messages and message batches up directly | ||
* (on the same thread), but passes OOB messages to the thread pool. | ||
* @author Bela Ban | ||
* @since 5.2.14 | ||
*/ | ||
public class PassRegularMessagesUpDirectly extends SubmitToThreadPool { | ||
|
||
@Override | ||
public boolean loopback(Message msg, boolean oob) { | ||
if(oob) | ||
return super.loopback(msg, oob); | ||
tp.passMessageUp(msg, null, false, msg.getDest() == null, false); | ||
return true; | ||
} | ||
|
||
@Override | ||
public boolean process(Message msg, boolean oob) { | ||
if(oob) | ||
return super.process(msg, oob); | ||
SingleMessageHandler smh=new SingleMessageHandler(msg); | ||
smh.run(); | ||
return true; | ||
} | ||
|
||
@Override | ||
public boolean process(MessageBatch batch, boolean oob) { | ||
if(oob) | ||
return super.process(batch, oob); | ||
BatchHandler bh=new BatchHandler(batch); | ||
bh.run(); | ||
return true; | ||
} | ||
} |