osmq.messages
Class MessageFactory
java.lang.Object
osmq.messages.MessageFactory
- public class MessageFactory
- extends java.lang.Object
Each thread should allocate a seperate MessageFactory instance;
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageFactory
public MessageFactory()
createNotificationMessage
public static DataSetMessage createNotificationMessage(int size,
java.lang.String topic)
createMessage
public static Message createMessage(byte[] value)
throws MessageException
- Creates an DataSetMessageBean or BinaryMessageBean, depending on
the value of the message format found in the byte array.
- Throws:
MessageException
createMessage
public static DataSetMessage createMessage(int sz)
createDataSetMessage
public static DataSetMessage createDataSetMessage(java.lang.String v)
createImmutableMessage
public static DataSetMessage createImmutableMessage(java.lang.String v)
createImmutableMessage
public static Message createImmutableMessage(byte[] b)
throws MessageException
- Throws:
MessageException