public abstract class MConsumer extends java.lang.Object implements MObject
Modifier and Type | Field and Description |
---|---|
protected MConsumerImpl |
m_consumerImpl |
protected MEndpointSpec |
m_endpointSpec |
protected boolean |
m_isActivated |
protected boolean |
m_isAutoConfirm |
AMX, JMS, M_FILE_SINK_ID, M_HAWK_SINK_ID, M_JMS_SINK_ID, M_RV_SINK_ID, M_SINK_ID, M_STDERR_SINK_ID, M_STDOUT_SINK_ID, M_STREAM_SINK_ID, RV
Modifier | Constructor and Description |
---|---|
protected |
MConsumer(MEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
activate() |
void |
addListener(MEventListener p_listener) |
void |
addTPluginName(java.lang.String sTPluginName) |
void |
deactivate() |
boolean |
doesExplicitConfirmation() |
int |
getDeliveryMode() |
java.lang.Object |
getDestination() |
java.lang.String |
getDestinationName() |
java.util.Enumeration |
getListeners() |
abstract MSession |
getSession() |
long |
getTimeout() |
java.util.Vector |
getTPluginNames() |
boolean |
hasListeners() |
abstract void |
noAutoConfirm() |
void |
notify(MEvent p_event) |
MEventListener |
removeListener(MEventListener p_listener) |
void |
setDestinationName(java.lang.String destinationName) |
void |
suspend() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTransportID
protected MConsumerImpl m_consumerImpl
protected MEndpointSpec m_endpointSpec
protected volatile boolean m_isActivated
protected boolean m_isAutoConfirm
protected MConsumer(MEndpointSpec endpointSpec)
public void activate() throws MException
MException
public void deactivate() throws MException
MException
public void suspend() throws MException
MException
public void addListener(MEventListener p_listener)
public java.util.Enumeration getListeners()
public boolean hasListeners()
public MEventListener removeListener(MEventListener p_listener)
public void notify(MEvent p_event)
public int getDeliveryMode()
public void setDestinationName(java.lang.String destinationName)
public java.lang.String getDestinationName()
public abstract MSession getSession()
public long getTimeout()
public void addTPluginName(java.lang.String sTPluginName)
public java.util.Vector getTPluginNames()
public abstract void noAutoConfirm() throws MException
MException
public boolean doesExplicitConfirmation()
public java.lang.Object getDestination()