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
Constructor and Description |
---|
MRvProducer(MComponentRegistry registry,
java.lang.String name,
MSession p_session,
MEndpointSpec endpointSpec) |
Modifier and Type | Method and Description |
---|---|
void |
addTPluginName(java.lang.String sTPluginName) |
void |
assignMsgGUID(boolean assignGUID) |
boolean |
getAssignMsgGUID() |
int |
getDeliveryMode() |
java.lang.String |
getDestinationName() |
MEndpointSpec |
getEndpointSpec() |
long |
getNumMessagesPublished() |
java.lang.String |
getReplyDestinationName() |
long |
getSequenceNumber() |
int |
getTransportID() |
boolean |
isAeMsgOn() |
void |
preRegisterListener(java.lang.String listenerName) |
void |
send(MTree data) |
void |
sendWithReply(MTree msg,
MSubscriber subscriber) |
MTree |
sendWithSyncReply(MTree msg,
long timeout) |
void |
setAeMsgOn(boolean aeMsgOn) |
void |
setCmTimeLimit(long p_timeLimit) |
void |
setDestinationName(java.lang.String destinationName) |
void |
setReplyDestinationName(java.lang.String replyDestinationName) |
void |
unRegisterListener(java.lang.String listenerName) |
disableJmsMessageId, setJmsCorrelationId, setJmsPriority
public MRvProducer(MComponentRegistry registry, java.lang.String name, MSession p_session, MEndpointSpec endpointSpec) throws MException
MException
public void send(MTree data) throws MException
send
in class MProducer
MException
public void sendWithReply(MTree msg, MSubscriber subscriber) throws MException
sendWithReply
in class MProducer
MException
public MTree sendWithSyncReply(MTree msg, long timeout) throws MException
sendWithSyncReply
in class MProducer
MException
public void setCmTimeLimit(long p_timeLimit) throws MException
MException
public long getSequenceNumber() throws MException
MException
public void preRegisterListener(java.lang.String listenerName) throws MException
MException
public void unRegisterListener(java.lang.String listenerName) throws MException
unRegisterListener
in class MProducer
MException
public int getTransportID()
public java.lang.String getDestinationName()
getDestinationName
in class MProducer
public void setDestinationName(java.lang.String destinationName) throws MException
setDestinationName
in class MProducer
MException
public void setReplyDestinationName(java.lang.String replyDestinationName)
setReplyDestinationName
in class MProducer
public java.lang.String getReplyDestinationName()
getReplyDestinationName
in class MProducer
public int getDeliveryMode()
getDeliveryMode
in class MProducer
public void assignMsgGUID(boolean assignGUID)
public boolean getAssignMsgGUID()
public void setAeMsgOn(boolean aeMsgOn)
setAeMsgOn
in class MProducer
public long getNumMessagesPublished()
getNumMessagesPublished
in class MProducer
public MEndpointSpec getEndpointSpec()
getEndpointSpec
in class MProducer
public void addTPluginName(java.lang.String sTPluginName)
addTPluginName
in class MProducer