Package com.skava.oms.message
Class OmsMessageSender
java.lang.Object
com.skava.oms.message.OmsMessageSender
@Configuration
@Component
@ConditionalOnProperty(prefix="skava.event.rabbitmq",
name="enabled",
havingValue="true")
public class OmsMessageSender
extends Object
The class is used to send the messages from oms
- Since:
- 09-Jul-2018
-
Field Summary
FieldsModifier and TypeFieldDescriptionfinal com.skava.core.properties.AuthorizationProperties
aoth propertiesfinal CollectionHelper
static final String
CollectionId as constantstatic final String
static final String
static final String
UserId as constant -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
send
(com.skava.core.event.Message<?> omsMessage, String topicName, String queueName, String routingkey, Map<String, Object> messageHeader) Message event sender by topic exchange or queue name If default message queue enabled in oms properties this will override queue name to default oms queuevoid
sendExternalEvent
(com.skava.core.event.Message<?> omsMessage, Map<String, Object> messageHeader) External Message event sender by topic exchange or queue name If default message queue enabled in oms properties this will override queue name to default oms queue
-
Field Details
-
authProps
public final com.skava.core.properties.AuthorizationProperties authPropsaoth properties -
collectionHelper
-
COLLECTIONID
CollectionId as constant- See Also:
-
USERID
UserId as constant- See Also:
-
EVENT_TYPE
- See Also:
-
ORDER_ID
- See Also:
-
-
Constructor Details
-
OmsMessageSender
public OmsMessageSender()
-
-
Method Details
-
send
public void send(com.skava.core.event.Message<?> omsMessage, String topicName, String queueName, String routingkey, Map<String, Object> messageHeader) Message event sender by topic exchange or queue name If default message queue enabled in oms properties this will override queue name to default oms queue- Parameters:
omsMessage
- Order MessagetopicName
- Topic exchange namequeueName
- Queue name of the messageroutingkey
- - routing key of the messagemessageHeader
- custom message header key and values
-
sendExternalEvent
public void sendExternalEvent(com.skava.core.event.Message<?> omsMessage, Map<String, Object> messageHeader) External Message event sender by topic exchange or queue name If default message queue enabled in oms properties this will override queue name to default oms queue- Parameters:
omsMessage
- Order MessagemessageHeader
- custom message header key and values
-