formatting
This commit is contained in:
@@ -38,11 +38,6 @@ public class ThreadLocalChannel extends AbstractPollableChannel {
|
||||
private static final ThreadLocalMessageHolder messageHolder = new ThreadLocalMessageHolder();
|
||||
|
||||
|
||||
@Override
|
||||
protected Message<?> doReceive(long timeout) {
|
||||
return messageHolder.get().poll();
|
||||
}
|
||||
|
||||
@Override
|
||||
protected boolean doSend(Message<?> message, long timeout) {
|
||||
if (message == null) {
|
||||
@@ -51,6 +46,11 @@ public class ThreadLocalChannel extends AbstractPollableChannel {
|
||||
return messageHolder.get().add(message);
|
||||
}
|
||||
|
||||
@Override
|
||||
protected Message<?> doReceive(long timeout) {
|
||||
return messageHolder.get().poll();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* The thread-bound Queue.
|
||||
|
||||
Reference in New Issue
Block a user