Compatibility - ApsaraMQ for RabbitMQ - Alibaba Cloud Documentation Center

This article describes the implementation of the JMS 1.1 API on JMS clients for ApsaraMQ for RabbitMQ.

JMS interfaces

Connection factory interfaces
Server session interfaces
Connection interfaces
Session interfaces
Consumer and producer interfaces
Message interfaces
Message consumer interfaces
Destination interfaces

Connection factory interfaces

Table 1. ConnectionFactory
Interface	Compatibility
Connection CreateConnection()	Supported
Connection CreateConnection(java.lang.String userName, java.lang.String password)	Supported

Table 2. QueueConnectionFactory
Interface	Compatibility
QueueConnection CreateQueueConnection()	Supported
QueueConnection CreateQueueConnection(java.lang.String userName, java.lang.String password)	Supported

Table 3. TopicConnectionFactory
Interface	Compatibility
TopicConnection CreateTopicConnection()	Supported
TopicConnection CreateTopicConnection(java.lang.String userName, java.lang.String password)	Supported

Table 4. XAQueueConnectionFactory
Interface	Compatibility
XAQueueConnection CreateXAQueueConnection()	Not supported
XAQueueConnection CreateXAQueueConnection(java.lang.String userName, java.lang.String password)	Not supported

Table 5. XATopicConnectionFactory
Interface	Compatibility
XATopicConnection CreateXATopicConnection()	Not supported
XATopicConnection CreateXATopicConnection(java.lang.String userName, java.lang.String password)	Not supported

Server session interfaces

Table 6. ServerSessionPool
Interface	Compatibility
ServerSession getServerSession()	Not supported

Table 7. ServerSession
Interface	Compatibility
Session getSession()	Not supported
void start()	Not supported

Connection interfaces

Table 8. Connection
Interface	Compatibility
Session createSession(boolean transacted, int acknowledgeMode)	Supported
java.lang.String getClientID()	Supported
void setClientID(java.lang.String clientID)	Supported
ConnectionMetaData getMetaData()	Not implemented
ExceptionListener getExceptionListener()	Supported
void setExceptionListener(ExceptionListener listener)	Supported
void start()	Supported
void stop()	Supported
void close()	Supported
ConnectionConsumer createConnectionConsumer(Destination destination, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)	Not supported
ConnectionConsumer createDurableConnectionConsumer(Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)	Not supported

Table 9. QueueConnection
Interface	Compatibility
QueueSession createQueueSession(boolean transacted, int acknowledgeMode)	Supported
ConnectionConsumer createConnectionConsumer(Queue queue, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)	Not supported

Table 10. TopicConnection
Interface	Compatibility
TopicSession createTopicSession(boolean transacted, int acknowledgeMode)	Supported
ConnectionConsumer createConnectionConsumer(Topic topic, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)	Not supported
ConnectionConsumer createDurableConnectionConsumer(Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, ServerSessionPool sessionPool, int maxMessages)	Not supported

Table 11. XAConnection
Interface	Compatibility
XASession createXASession()	Not implemented
Session createSession(boolean transacted, int acknowledgeMode)	Not implemented

Table 12. XAQueueConnection
Interface	Compatibility
XAQueueSession createXAQueueSession()	Not implemented
QueueSession createQueueSession(boolean transacted, int acknowledgeMode)	Not implemented

Table 13. XATopicConnection
Interface	Compatibility
XATopicSession createXATopicSession()	Not implemented
TopicSession createTopicSession(boolean transacted, int acknowledgeMode)	Not implemented

Session interfaces

Table 14. Session
Interface	Compatibility
BytesMessage createBytesMessage()	Supported
MapMessage createMapMessage()	Supported
Message createMessage()	Supported
ObjectMessage createObjectMessage()	Supported
ObjectMessage createObjectMessage(java.io.Serializable object)	Supported
StreamMessage createStreamMessage()	Supported
TextMessage createTextMessage()	Supported
TextMessage createTextMessage(java.lang.String text)	Supported
boolean getTransacted()	Supported
int getAcknowledgeMode()	Supported
void commit()	Supported
void rollback()	Supported
void close()	Supported
void recover()	Supported
MessageListener getMessageListener()	Supported
void setMessageListener(MessageListener listener)	Supported
void run()	Not supported
MessageProducer createProducer(Destination destination)	Supported
MessageConsumer createConsumer(Destination destination)	Supported
MessageConsumer createConsumer(Destination destination, java.lang.String messageSelector)	Not implemented: non-null messageSelector
MessageConsumer createConsumer(Destination destination, java.lang.String messageSelector, boolean NoLocal)	Not implemented: non-null messageSelector Accepted but ignored: NoLocal
Queue createQueue(java.lang.String queueName)	Supported
Topic createTopic(java.lang.String topicName)	Supported
TopicSubscriber createDurableSubscriber(Topic topic, java.lang.String name)	Supported
TopicSubscriber createDurableSubscriber(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal)	Not supported: NoLocal
QueueBrowser createBrowser(Queue queue)	Not implemented
QueueBrowser createBrowser(Queue queue, java.lang.String messageSelector)	Not implemented
TemporaryQueue createTemporaryQueue()	Supported
TemporaryTopic createTemporaryTopic()	Supported
void unsubscribe(java.lang.String name)	Supported only for durable subscriptions

Table 15. TopicSession
Interface	Compatibility
Topic createTopic(java.lang.String topicName)	Supported
TopicSubscriber createSubscriber(Topic topic, java.lang.String messageSelector, boolean noLocal)	Not supported: NoLocal
TopicSubscriber createSubscriber(Topic topic)	Supported
TopicSubscriber createDurableSubscriber(Topic topic, java.lang.String name)	Supported

Table 16. QueueSession
Interface	Compatibility
Queue createQueue(java.lang.String queueName))	Supported
QueueReceiver createReceiver(Queue queue)	Supported
QueueReceiver createReceiver(Queue queue, java.lang.String messageSelector)	Not implemented
QueueSender createSender(Queue queue)	Supported
QueueBrowser createBrowser(Queue queue)	Supported
QueueBrowser createBrowser(Queue queue, java.lang.String messageSelector)	Supported
TemporaryQueue createTemporaryQueue()	Supported

Table 17. XAQueueSession
Interface	Compatibility
QueueSession getQueueSession()	Not implemented

Table 18. XASession
Interface	Compatibility
Session getSession()	Not implemented
XAResource getXAResource()	Not implemented
boolean getTransacted()	Not implemented
void commit()	Not implemented
void rollback()	Not implemented

Table 19. XATopicSession
Interface	Compatibility
TopicSession getTopicSession()	Not implemented

Consumer and producer interfaces

Table 20. ConnectionConsumer
Interface	Compatibility
ServerSessionPool getServerSessionPool()	Not supported
void close()	Not supported

Table 21. MessageProducer
Interface	Compatibility
void setDisableMessageID(boolean value)	Ignored
boolean getDisableMessageID()	Ignored
void setDisableMessageTimestamp(boolean value)	Ignored
boolean getDisableMessageTimestamp()	Ignored
void setDeliveryMode(int deliveryMode)	Supported
int getDeliveryMode()	Supported
void setPriority(int defaultPriority)	Supported
int getPriority()	Supported
void setTimeToLive(long timeToLive)	Supported
long getTimeToLive()	Supported
Destination getDestination()	Supported
void close()	Supported
void send(Message message)	Supported
void send(Message message, int deliveryMode, int priority, long timeToLive)	Supported
void send(Destination destination, Message message)	Supported
void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive)	Supported

Table 22. QueueSender
Interface	Compatibility
Queue getQueue()	Supported
void send(Message message)	Supported
void send(Message message, int deliveryMode, int priority, long timeToLive)	Supported
void send(Queue queue, Message message)	Supported
void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLive)	Supported

Table 23. TopicPublisher
Interface	Compatibility
Topic getTopic()	Supported
void publish(Message message)	Supported
void publish(Message message, int deliveryMode, int priority, long timeToLive)	Supported
void publish(Topic topic, Message message)	Supported
void publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive)	Supported

Message interfaces

Table 24. Message
Interface	Compatibility
java.lang.String getJMSMessageID()	Supported
void setJMSMessageID(java.lang.String id)	Supported
long getJMSTimestamp()	Supported
void setJMSTimestamp(long timestamp)	Supported
byte[] getJMSCorrelationIDAsBytes()	Supported
void setJMSCorrelationIDAsBytes(byte[] correlationID)	Supported
void setJMSCorrelationID(java.lang.String correlationID)	Supported
java.lang.String getJMSCorrelationID()	Supported
Destination getJMSReplyTo()	Supported
void setJMSReplyTo(Destination replyTo)	Supported
Destination getJMSDestination()	Supported
void setJMSDestination(Destination destination)	Supported
int getJMSDeliveryMode()	Supported
void setJMSDeliveryMode(int deliveryMode)	Supported
boolean getJMSRedelivered()	Supported
void setJMSRedelivered(boolean redelivered)	Supported
java.lang.String getJMSType()	Supported
void setJMSType(java.lang.String type)	Supported
long getJMSExpiration()	Supported
void setJMSExpiration(long expiration)	Supported
int getJMSPriority()	Supported
void setJMSPriority(int priority)	Supported
void clearProperties()	Supported
boolean propertyExists(java.lang.String name)	Supported
boolean getBooleanProperty(java.lang.String name)	Supported
byte getByteProperty(java.lang.String name)	Supported
short getShortProperty(java.lang.String name)	Supported
int getIntProperty(java.lang.String name)	Supported
long getLongProperty(java.lang.String name)	Supported
float getFloatProperty(java.lang.String name)	Supported
double getDoubleProperty(java.lang.String name)	Supported
java.lang.String getStringProperty(java.lang.String name)	Supported
java.lang.Object getObjectProperty(java.lang.String name)	Supported
java.util.Enumeration getPropertyNames()	Supported
void setBooleanProperty(java.lang.String name, boolean value)	Supported
void setShortProperty(java.lang.String name, short value)	Supported
void setIntProperty(java.lang.String name, int value)	Supported
void setLongProperty(java.lang.String name, long value)	Supported
void setFloatProperty(java.lang.String name, float value)	Supported
void setDoubleProperty(java.lang.String name, double value)	Supported
void setStringProperty(java.lang.String name, java.lang.String value)	Supported
void setObjectProperty(java.lang.String name, java.lang.Object value)	Supported
void acknowledge()	Supported
void clearBody()	Supported

Table 25. BytesMessage
Interface	Compatibility
long getBodyLength()	Supported
boolean readBoolean()	Supported
byte readByte()	Supported
int readUnsignedByte()	Supported
short readShort()	Supported
int readUnsignedShort()	Supported
char readChar()	Supported
int readInt()	Supported
long readLong()	Supported
float readFloat()	Supported
double readDouble()	Supported
java.lang.String readUTF()	Supported
int readBytes(byte[] value)	Supported
int readBytes(byte[] value, int length)	Supported
void writeBoolean(boolean value)	Supported
void writeByte(byte value)	Supported
void writeShort(short value)	Supported
void writeChar(char value)	Supported
void writeInt(int value)	Supported
void writeLong(long value)	Supported
void writeFloat(float value)	Supported
void writeDouble(double value)	Supported
void writeUTF(java.lang.String value)	Supported
void writeBytes(byte[] value)	Supported
void writeBytes(byte[] value, int offset, int length)	Supported
void writeObject(java.lang.Object value)	Supported
void reset()	Supported

Table 26. MapMessag
Interface	Compatibility
boolean getBoolean(java.lang.String name)	Supported
byte getByte(java.lang.String name)	Supported
short getShort(java.lang.String name)	Supported
char getChar(java.lang.String name)	Supported
int getInt(java.lang.String name)	Supported
long getLong(java.lang.String name)	Supported
float getFloat(java.lang.String name)	Supported
double getDouble(java.lang.String name)	Supported
java.lang.String getString(java.lang.String name)	Supported
byte[] getBytes(java.lang.String name)	Supported
java.lang.Object getObject(java.lang.String name)	Supported
java.util.Enumeration getMapNames()	Supported
void setBoolean(java.lang.String name, boolean value)	Supported
void setByte(java.lang.String name, byte value)	Supported
void setShort(java.lang.String name, short value)	Supported
void setChar(java.lang.String name, char value)	Supported
void setInt(java.lang.String name, int value)	Supported
void setLong(java.lang.String name, long value)	Supported
void setFloat(java.lang.String name, float value)	Supported
void setDouble(java.lang.String name, double value)	Supported
void setString(java.lang.String name, java.lang.String value)	Supported
void setBytes(java.lang.String name, byte[] value)	Supported
void setBytes(java.lang.String name, byte[] value, int offset, int length)	Supported
void setObject(java.lang.String name, java.lang.Object value)	Supported
boolean itemExists(java.lang.String name)	Supported

Table 27. ObjectMessage
Interface	Compatibility
void setObject(java.io.Serializable object)	Supported
java.io.Serializable getObject()	Supported

Table 28. StreamMessage
Interface	Compatibility
boolean readBoolean()	Supported
byte readByte()	Supported
short readShort()	Supported
char readChar()	Supported
int readInt()	Supported
long readLong()	Supported
float readFloat()	Supported
double readDouble()	Supported
java.lang.String readString()	Supported
int readBytes(byte[] value)	Supported
java.lang.Object readObject()	Supported
void writeBoolean(boolean value)	Supported
oid writeByte(byte value)	Supported
void writeShort(short value)	Supported
void writeChar(char value)	Supported
void writeInt(int value)	Supported
void writeLong(long value)	Supported
void writeFloat(float value)	Supported
void writeDouble(double value)	Supported
void writeString(java.lang.String value)	Supported
void writeBytes(byte[] value)	Supported
void writeBytes(byte[] value, int offset, int length)	Supported
void writeObject(java.lang.Object value)	Supported
void reset()	Supported

Table 29. TextMessage
Interface	Compatibility
void setText(java.lang.String string)	Supported
java.lang.String getText()	Supported

Message consumer interfaces

Table 30. MessageConsumer
Interface	Compatibility
java.lang.String getMessageSelector()	Supported
MessageListener getMessageListener()	Supported
void setMessageListener(MessageListener listener)	Supported
Message receive()	Supported
Message receive(long timeout)	Supported
Message receiveNoWait()	Supported
void close()	Supported

Table 31. QueueReceiver
Interface	Compatibility
Queue getQueue()	Supported

Table 32. TopicSubscriber
Interface	Compatibility
Topic getTopic()	Supported
boolean getNoLocal()	Not supported: NoLocal

Destination interfaces

Table 33. Destination
Interface	Compatibility
N/A	N/A

Table 34. Queue
Interface	Compatibility
java.lang.String getQueueName()	Supported
java.lang.String toString()	Supported

Table 35. TemporaryQueue
Interface	Compatibility
void delete()	Supported

Table 36. Topic
Interface	Compatibility
java.lang.String getTopicName()	Supported
java.lang.String toString()	Supported

Table 37. TemporaryTopic
Interface	Compatibility
void delete()	Supported

Table 38. QueueBrowser
Interface	Compatibility
Queue getQueue()	Supported
java.lang.String getMessageSelector()	Supported
java.util.Enumeration getEnumeration()	Supported
void close()	Supported