public class AgentMessageSource extends GenericService implements MessageSource
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CLASS_VERSION
Class version string
|
SERVICE_INFO_KEY
DEFAULT_LOG_TRACE_STATUS
DEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS
Constructor and Description |
---|
AgentMessageSource() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getDefaultPortName() |
MessageSourceContext |
getMessageSourceContext() |
javax.transaction.TransactionManager |
getTransactionManager() |
void |
sendAgentEventMessage(AgentEvent pAgentEvent,
java.lang.String pJmsType)
Sends an agent message using the port defined by the
defaultPortName
|
void |
sendAgentEventMessage(AgentEvent pAgentEvent,
java.lang.String pPortName,
java.lang.String pJmsType)
Sends an agent message using the specified port.
|
protected void |
sendMessage(java.io.Serializable pMessageBean,
java.lang.String pPortName,
java.lang.String pJmsType)
Sends the message bean using the specified port name and jms type
|
void |
setDefaultPortName(java.lang.String pDefaultPortName)
property DefaultPortName
|
void |
setMessageSourceContext(MessageSourceContext pContext)
property messageSourceContext
|
void |
setTransactionManager(javax.transaction.TransactionManager pTransactionManager)
property transactionManager
|
void |
startMessageSource()
Instructs this message source to begin distributing messages.
|
void |
stopMessageSource()
Instructs this message source to begin distributing messages.
|
addLogListener, createAdminServlet, doStartService, doStopService, getAbsoluteName, getAdminServlet, getAdminServletOutputStreamEncoding, getLoggingForVlogging, getLogListenerCount, getLogListeners, getName, getNameContext, getNucleus, getRoot, getServiceConfiguration, getServiceInfo, isAdminServletUseServletOutputStream, isLoggingDebug, isLoggingError, isLoggingInfo, isLoggingTrace, isLoggingWarning, isRunning, logDebug, logDebug, logDebug, logError, logError, logError, logInfo, logInfo, logInfo, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, nameContextElementBound, nameContextElementUnbound, removeLogListener, reResolveThis, resolveName, resolveName, resolveName, resolveName, sendLogEvent, setAdminServletOutputStreamEncoding, setAdminServletUseServletOutputStream, setLoggingDebug, setLoggingError, setLoggingInfo, setLoggingTrace, setLoggingWarning, setNucleus, setServiceInfo, startService, stopService
vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarning
public static final java.lang.String CLASS_VERSION
public void setDefaultPortName(java.lang.String pDefaultPortName)
The port name used by default for sending message through dms.
public java.lang.String getDefaultPortName()
public void setTransactionManager(javax.transaction.TransactionManager pTransactionManager)
The Transaction Manager instance used when sending messages.
public javax.transaction.TransactionManager getTransactionManager()
public void setMessageSourceContext(MessageSourceContext pContext)
setMessageSourceContext
in interface MessageSource
public MessageSourceContext getMessageSourceContext()
public void startMessageSource()
startMessageSource
in interface MessageSource
public void stopMessageSource()
stopMessageSource
in interface MessageSource
public void sendAgentEventMessage(AgentEvent pAgentEvent, java.lang.String pJmsType)
pAgentEvent
- the event objectpJmsType
- the jms type for sending the eventpublic void sendAgentEventMessage(AgentEvent pAgentEvent, java.lang.String pPortName, java.lang.String pJmsType)
pAgentEvent
- the event objectpPortName
- the port name used to send the messagepJmsType
- the jms type for sending the eventsendMessage(Serializable, String, String)
protected void sendMessage(java.io.Serializable pMessageBean, java.lang.String pPortName, java.lang.String pJmsType)
If the port name is not provided, the defaultPortName
is used.
pMessageBean
- the message objectpPortName
- the port name to use. This will default to the defaultPortName
if one is not supplied.pJmsType
- the jms type used for sending the event