org.omg.Messaging

---

1. Creating a Message

import org.omg.Messaging.Message;

// Create a new message
Message msg = new Message();

// Set the message body
msg.setBody(<your_message_body>);

2. Sending a Message

import org.omg.Messaging.ORB;
import org.omg.Messaging.Message;

// Get the ORB (Object Request Broker)
ORB orb = ORB.init();

// Create a message
Message msg = new Message();
msg.setBody(<your_message_body>);

// Send the message
orb.send(msg);

3. Receiving a Message

import org.omg.Messaging.ORB;
import org.omg.Messaging.Message;

// Get the ORB (Object Request Broker)
ORB orb = ORB.init();

// Register a callback to receive messages
ORB.setCallbacks(<your_callback_implementation>);

// Wait for a message to arrive
Message msg = orb.receive();

4. Replying to a Message

import org.omg.Messaging.ORB;
import org.omg.Messaging.Message;

// Get the ORB (Object Request Broker)
ORB orb = ORB.init();

// Create a message to reply with
Message reply = new Message();
reply.setBody(<your_reply_body>);

// Set the reply-to address
reply.setReplyTo(<recipient_address>);

// Send the reply
orb.send(reply);

5. Forwarding a Message

import org.omg.Messaging.ORB;
import org.omg.Messaging.Message;

// Get the ORB (Object Request Broker)
ORB orb = ORB.init();

// Create a message to forward
Message forward = new Message();
forward.setBody(<your_message_body>);

// Set the forward-to address
forward.setForwardTo(<forward_address>);

// Send the forwarded message
orb.send(forward);

6. Filtering Messages

import org.omg.Messaging.Message;
import org.omg.Messaging.Filterable;

// Create a message filter
Filterable filter = new Filterable();

// Set the filter criteria
filter.setType(<message_type>);
filter.setSender(<sender_address>);

// Apply the filter
Message filteredMessage = message.getMessageWithFilter(filter);

7. Retrieving Message Properties

import org.omg.Messaging.Message;

// Get the message properties
Properties properties = message.getProperties();

// Retrieve a specific property
String propertyValue = properties.getProperty(<property_name>);

8. Creating a Message Context

import org.omg.Messaging.MessageContext;

// Create a new message context
MessageContext context = new MessageContext();

// Set context properties
context.setProperty(<property_name>, <property_value>);

9. Getting the Message Context

import org.omg.Messaging.Message;

// Get the message context
MessageContext context = message.getMessageContext();

10. Setting the Message Context

import org.omg.Messaging.Message;
import org.omg.Messaging.MessageContext;

// Create a new message context
MessageContext context = new MessageContext();

// Set the message context
message.setMessageContext(context);

11. Creating a Request Message

import org.omg.Messaging.RequestMessage;

// Create a new request message
RequestMessage request = new RequestMessage();

// Set request properties
request.setOperation(<operation_name>);
request.setArguments(<arguments>);

12. Getting the Request Message

import org.omg.Messaging.Message;

// Get the request message
RequestMessage request = message.getRequestMessage();

13. Setting the Request Message

import org.omg.Messaging.Message;
import org.omg.Messaging.RequestMessage;

// Create a new request message
RequestMessage request = new RequestMessage();

// Set the request message
message.setRequestMessage(request);

14. Creating a Reply Message

import org.omg.Messaging.ReplyMessage;

// Create a new reply message
ReplyMessage reply = new ReplyMessage();

// Set reply properties
reply.setException(<exception>);
reply.setResult(<result>);

15. Getting the Reply Message

import org.omg.Messaging.Message;

// Get the reply message
ReplyMessage reply = message.getReplyMessage();

16. Setting the Reply Message

import org.omg.Messaging.Message;
import org.omg.Messaging.ReplyMessage;

// Create a new reply message
ReplyMessage reply = new ReplyMessage();

// Set the reply message
message.setReplyMessage(reply);

17. Creating a Message Property

import org.omg.Messaging.MessageProperty;

// Create a new message property
MessageProperty property = new MessageProperty();

// Set property name and value
property.setName(<property_name>);
property.setValue(<property_value>);

18. Getting the Message Property

import org.omg.Messaging.Message;

// Get the message property
MessageProperty property = message.getProperty(<property_name>);

19. Setting the Message Property

import org.omg.Messaging.Message;
import org.omg.Messaging.MessageProperty;

// Create a new message property
MessageProperty property = new MessageProperty();

// Set property name and value
property.setName(<property_name>);
property.setValue(<property_value>);

// Set the message property
message.setProperty(property);

20. Creating a Message Service

import org.omg.Messaging.MessageService;

// Create a new message service
MessageService service = new MessageService();

// Set service properties
service.setConnectionName(<connection_name>);
service.setMessageListener(<listener>);

21. Getting the Message Service

import org.omg.Messaging.ORB;

// Get the message service
MessageService service = orb.getMessageService();

22. Setting the Message Service

import org.omg.Messaging.ORB;
import org.omg.Messaging.MessageService;

// Create a new message service
MessageService service = new MessageService();

// Set the message service
orb.setMessageService(service);

23. Creating a Message Bundle

import org.omg.Messaging.MessageBundle;

// Create a new message bundle
MessageBundle bundle = new MessageBundle();

// Add messages to the bundle
bundle.add(<message1>);
bundle.add(<message2>);

24. Getting the Message Bundle

import org.omg.Messaging.ORB;

// Get the message bundle
MessageBundle bundle = orb.getMessageBundle();

25. Setting the Message Bundle

import org.omg.Messaging.ORB;
import org.omg.Messaging.MessageBundle;

// Create a new message bundle
MessageBundle bundle = new MessageBundle();

// Set the message bundle
orb.setMessageBundle(bundle);

26. Creating a Delivery Mode

import org.omg.Messaging.DeliveryMode;

// Create a new delivery mode
DeliveryMode mode = new DeliveryMode();

// Set delivery mode options
mode.setDeliveryPolicy(<policy>);
mode.setMaxDeliveryAttempts(<max_attempts>);

27. Getting the Delivery Mode

import org.omg.Messaging.Message;

// Get the delivery mode
DeliveryMode mode = message.getDeliveryMode();

28. Setting the Delivery Mode

import org.omg.Messaging.Message;
import org.omg.Messaging.DeliveryMode;

// Create a new delivery mode
DeliveryMode mode = new DeliveryMode();

// Set delivery mode options
mode.setDeliveryPolicy(<policy>);
mode.setMaxDeliveryAttempts(<max_attempts>);

// Set the delivery mode
message.setDeliveryMode(mode);

29. Creating a QoS

import org.omg.Messaging.QoS;

// Create a new QoS
QoS qos = new QoS();

// Set QoS properties
qos.setBestEffort(<best_effort>);
qos.setReliability(<reliability>);

30. Getting the QoS

import org.omg.Messaging.Message;

// Get the QoS
QoS qos = message.getQoS();

31. Setting the QoS

import org.omg.Messaging.Message;
import org.omg.Messaging.QoS;

// Create a new QoS
QoS qos = new QoS();

// Set QoS properties
qos.setBestEffort(<best_effort>);
qos.setReliability(<reliability>);

// Set the QoS
message.setQoS(qos);

32. Creating a Request Time Limits

import org.omg.Messaging.RequestTimeLimits;

// Create a new request time limits
RequestTimeLimits limits = new RequestTimeLimits();

// Set time limits
limits.setRequestTimeout(<timeout>);
limits.setTransactionTimeout(<transaction_timeout>);

33. Getting the Request Time Limits

import org.omg.Messaging.Message;

// Get the request time limits
RequestTimeLimits limits = message.getRequestTimeLimits();

34. Setting the Request Time Limits

import org.omg.Messaging.Message;
import org.omg.Messaging.RequestTimeLimits;

// Create a new request time limits
RequestTimeLimits limits = new RequestTimeLimits();

// Set time limits
limits.setRequestTimeout(<timeout>);
limits.setTransactionTimeout(<transaction_timeout>);

// Set the request time limits
message.setRequestTimeLimits(limits);

35. Creating a Reply Time Limits

import org.omg.Messaging.ReplyTimeLimits;

// Create a new reply time limits
ReplyTimeLimits limits = new ReplyTimeLimits();

// Set time limits
limits.setReplyTimeout(<timeout>);
limits.setTransactionTimeout(<transaction_timeout>);

36. Getting the Reply Time Limits

import org.omg.Messaging.Message;

// Get the reply time limits
ReplyTimeLimits limits = message.getReplyTimeLimits();

37. Setting the Reply Time Limits

import org.omg.Messaging.Message;
import org.omg.Messaging.ReplyTimeLimits;

// Create a new reply time limits
ReplyTimeLimits limits = new ReplyTimeLimits();

// Set time limits
limits.setReplyTimeout(<timeout>);
limits.setTransactionTimeout(<transaction_timeout>);

// Set the reply time limits
message.setReplyTimeLimits(limits);

38. Creating a Message Channel

import org.omg.Messaging.MessageChannel;

// Create a new message channel
MessageChannel channel = new MessageChannel();

// Set channel properties
channel.setChannelName(<channel_name>);
channel.setChannelMode(<channel_mode>);

39. Getting the Message Channel

import org.omg.Messaging.ORB;

// Get the message channel
MessageChannel channel = orb.getMessageChannel();

40. Setting the Message Channel

import org.omg.Messaging.ORB;
import org.omg.Messaging.MessageChannel;

// Create a new message channel
MessageChannel channel = new MessageChannel();

// Set channel properties
channel.setChannelName(<channel_name>);
channel.setChannelMode(<channel_mode>);

// Set the message channel
orb.setMessageChannel(channel);

41. Creating a Message Context

import org.omg.Messaging.MessageContext;

// Create a new message context
MessageContext context = new MessageContext();

// Set context properties
context.setProperty(<property_name>, <property_value>);

42. Getting the Message Context

import org.omg.Messaging.Message;

// Get the message context
MessageContext context = message.getMessageContext();

43. Setting the Message Context

import org.omg.Messaging.Message;
import org.omg.Messaging.MessageContext;

// Create a new message context
MessageContext context = new MessageContext();

// Set context properties
context.setProperty(<property_name>, <property_value>);

// Set the message context
message.setMessageContext(context);

44. Creating a Message Encoding

import org.omg.Messaging.MessageEncoding;

// Create a new message encoding
MessageEncoding encoding = new MessageEncoding();

// Set encoding properties
encoding.setEncoding(<encoding_type>);
encoding.setVersion(<version>);

45. Getting the Message Encoding

import org.omg.Messaging.Message;

// Get the message encoding
MessageEncoding encoding = message.getMessageEncoding();

46. Setting the Message Encoding

import org.omg.Messaging.Message;
import org.omg.Messaging.MessageEncoding;

// Create a new message encoding
MessageEncoding encoding = new MessageEncoding();

// Set encoding properties
encoding.setEncoding(<encoding_type>);
encoding.setVersion(<version>);

// Set the message encoding
message.setMessageEncoding(encoding);

47. Creating a Message Endpoint

import org.omg.Messaging.MessageEndpoint;

// Create a new message endpoint
MessageEndpoint endpoint = new MessageEndpoint();

// Set endpoint properties
endpoint.setEndpoint(<endpoint_address>);
endpoint.setPort(<port>);

48. Getting the Message Endpoint

import org.omg.Messaging.Message;

// Get the message endpoint
MessageEndpoint endpoint = message.getMessageEndpoint();

49. Setting the Message Endpoint

import org.omg.Messaging.Message;
import org.omg.Messaging.MessageEndpoint;

// Create a new message endpoint
MessageEndpoint endpoint = new MessageEndpoint();

// Set endpoint properties
endpoint.setEndpoint(<endpoint_address>);
endpoint.setPort(<port>);

// Set the message endpoint
message.setMessageEndpoint(endpoint);

50. Creating a Message Id

import org.omg.Messaging.MessageId;

// Create a new message id
MessageId id = new MessageId();

// Set id properties
id.setValue(<id_value>);
id.setSequenceNumber(<sequence_number>);