com.neeve.sma

Class MessageBusBinding.SynchronousNonBlockingFlushContext

java.lang.Object

com.neeve.sma.MessageBusBinding.FlushContext

com.neeve.sma.MessageBusBinding.SynchronousNonBlockingFlushContext

Enclosing interface:

MessageBusBinding

public static final class MessageBusBinding.SynchronousNonBlockingFlushContext
extends MessageBusBinding.FlushContext

Context for flushing using synchronous non-blocking semantics.

The user provides an instance of this class to MessageBusBinding.flush(com.neeve.sma.MessageBusBinding.FlushContext) or MessageChannel.sendMessage(com.neeve.sma.MessageView, java.util.Properties, com.neeve.sma.MessageBusBinding.FlushContext, int) to request for synchronous non-blocking flush semantics.

Nested Class Summary

Nested classes/interfaces inherited from class com.neeve.sma.MessageBusBinding.FlushContext

MessageBusBinding.FlushContext.FlushMode

Field Summary

Fields

Modifier and Type	Field and Description
boolean	complete Indicates whether the binding was flushed completely or not.

Fields inherited from class com.neeve.sma.MessageBusBinding.FlushContext

flushMode

Constructor Summary

Constructors

Constructor and Description
SynchronousNonBlockingFlushContext() Constructor

Method Summary

Modifier and Type	Method and Description
MessageBusBinding.FlushContext	reset() Implementation of MessageBusBinding.FlushContext.reset()
String	toString() String representation

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

complete

public boolean complete

Indicates whether the binding was flushed completely or not.

Upon successful return from MessageChannel.sendMessage(com.neeve.sma.MessageView, java.util.Properties, com.neeve.sma.MessageBusBinding.FlushContext, int), this field is set to true in case the send method implictly and completely flushed the binding. A value of false indicates that the binding was either not flushed at all or incompletely flushed. The return value from the send method used alongwith the value returned in this field can be used to distinguish between whether the binding was flushed incompletely or not at all.

Upon successful return from MessageBusBinding.flush(com.neeve.sma.MessageBusBinding.FlushContext), this field will be true in case the binding was flushed completely. A value of false indicates that the binding could not be flushed completely. In this case, the user should retry the flush at a later point.

Constructor Detail

SynchronousNonBlockingFlushContext

public SynchronousNonBlockingFlushContext()

Constructor

Method Detail

reset

public final MessageBusBinding.FlushContext reset()

Implementation of MessageBusBinding.FlushContext.reset()

Specified by:

reset in class MessageBusBinding.FlushContext

toString

public final String toString()

String representation

Overrides:

toString in class MessageBusBinding.FlushContext