atg.commerce.messaging

Class SourceSinkTemplate

java.lang.Object

atg.nucleus.logging.VariableArgumentApplicationLoggingImpl

atg.nucleus.GenericService

atg.dms.forward.SourceSinkTemplate

atg.commerce.messaging.SourceSinkTemplate

All Implemented Interfaces:

atg.core.logging.Logging, atg.core.logging.TraceLogging, MessageSink, MessageSource, atg.naming.AbsoluteNameable, NameContextBindingListener, NameContextElement, atg.naming.NameContextParentable, NameResolver, AdminableService, atg.nucleus.Configured, ApplicationLogging, atg.nucleus.logging.ApplicationLoggingSender, atg.nucleus.logging.TraceApplicationLogging, VariableArgumentApplicationLogging, ComponentNameResolver, Service, ServiceListener, java.util.EventListener

Direct Known Subclasses:

FulfillerSystem, LocalizingInventoryManager, LocalizingLocationInventoryManager, MessageForwardFilter, MessagePipelineMapper, MessageSender, OrderCanceller, OrderCanceller, OrderChangeHandler, PricingTools, RepositoryInventoryManager

public class SourceSinkTemplate
extends atg.dms.forward.SourceSinkTemplate

This class handles the sending and receiving of CommerceMessage. All classes in fulfillment that send and receive messages will extend this class. Classes that extend this will appear in the configuration XML file for patchbay.

See Also:

CommerceMessage

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CLASS_VERSION Class version string

Fields inherited from class atg.nucleus.GenericService

SERVICE_INFO_KEY

Fields inherited from interface atg.nucleus.logging.TraceApplicationLogging

DEFAULT_LOG_TRACE_STATUS

Fields inherited from interface atg.nucleus.logging.ApplicationLogging

DEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS

Constructor Summary

Constructors

Constructor and Description
SourceSinkTemplate()

Method Summary

Modifier and Type	Method and Description
void	receiveMessage(java.lang.String pPortName, javax.jms.Message pMessage) This is called to notify the component that a Message has arrived through the given input port.
void	sendCommerceMessage(CommerceMessage pCommerceMessage, java.lang.String pPortName) This is a convenience method which wraps the CommerceMessage to be sent into an ObjectMessage and sends it along the port that is specified.

Methods inherited from class atg.dms.forward.SourceSinkTemplate

beforeSendMessage, getDefaultMessageSourceName, getDelayOnSendRetry, getLimboDeliveryDelay, getMessageSourceContext, getMessageSourceName, getTransactionManager, isAllowMessageSending, sendObjectMessage, setAllowMessageSending, setDelayOnSendRetry, setLimboDeliveryDelay, setMessageSourceContext, setMessageSourceName, setTransactionManager, startMessageSource, stopMessageSource

Methods inherited from class atg.nucleus.GenericService

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, toString

Methods inherited from class atg.nucleus.logging.VariableArgumentApplicationLoggingImpl

vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarning

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

CLASS_VERSION

public static java.lang.String CLASS_VERSION

Class version string

Constructor Detail

SourceSinkTemplate

public SourceSinkTemplate()

Method Detail

sendCommerceMessage

public void sendCommerceMessage(CommerceMessage pCommerceMessage,
                                java.lang.String pPortName)
                         throws javax.jms.JMSException

This is a convenience method which wraps the CommerceMessage to be sent into an ObjectMessage and sends it along the port that is specified.

Parameters:

pCommerceMessage - The message to be sent.

pPortName - The port to send the message to.

Throws:

javax.jms.JMSException

receiveMessage

public void receiveMessage(java.lang.String pPortName,
                           javax.jms.Message pMessage)
                    throws javax.jms.JMSException

Description copied from interface: MessageSink

This is called to notify the component that a Message has arrived through the given input port. The MessageSink should be prepared to handle concurrent calls of this method from multiple Threads.

Specified by:

receiveMessage in interface MessageSink

Specified by:

receiveMessage in class atg.dms.forward.SourceSinkTemplate

Throws:

javax.jms.JMSException