at.ac.tuwien.infosys.jcloudscale.messaging

Interface IMQWrapper

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

AggregatedMQWrapper, MQWrapper

public interface IMQWrapper
extends Closeable

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	configurationEquals(MessageQueueConfiguration newConfiguration)
void	createQueueConsumer(String destName)
void	createQueueProducer(String destName)
void	createTopicConsumer(String destName)
void	createTopicConsumer(String destName, String messageSelector)
void	createTopicProducer(String destName)
void	disconnect()
void	oneway(MessageObject obj)
void	oneway(MessageObject obj, UUID correlationId)
void	onewayToCSHost(MessageObject obj, UUID correlationId, UUID hostId)
void	registerListener(javax.jms.MessageListener listener)
MessageObject	requestResponse(MessageObject obj, UUID correlationId)
MessageObject	requestResponse(MessageObject obj, UUID correlationId, CancellationToken cancelToken)
MessageObject	requestResponseToCSHost(MessageObject obj, UUID correlationId, UUID hostId)
MessageObject	requestResponseToCSHost(MessageObject obj, UUID correlationId, UUID hostId, CancellationToken cancelToken)
void	respond(MessageObject obj, javax.jms.Destination dest)
void	respond(MessageObject obj, javax.jms.Destination dest, UUID correlationId)

Method Detail

disconnect

void disconnect()
                throws javax.jms.JMSException,
                       NamingException

Throws:

javax.jms.JMSException

NamingException

close

void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

configurationEquals

boolean configurationEquals(MessageQueueConfiguration newConfiguration)

createQueueProducer

void createQueueProducer(String destName)
                         throws NamingException,
                                javax.jms.JMSException

Throws:

NamingException

javax.jms.JMSException

createTopicProducer

void createTopicProducer(String destName)
                         throws NamingException,
                                javax.jms.JMSException

Throws:

NamingException

javax.jms.JMSException

createQueueConsumer

void createQueueConsumer(String destName)
                         throws NamingException,
                                javax.jms.JMSException

Throws:

NamingException

javax.jms.JMSException

createTopicConsumer

void createTopicConsumer(String destName,
                       String messageSelector)
                         throws NamingException,
                                javax.jms.JMSException

Throws:

NamingException

javax.jms.JMSException

createTopicConsumer

void createTopicConsumer(String destName)
                         throws NamingException,
                                javax.jms.JMSException

Throws:

NamingException

javax.jms.JMSException

registerListener

void registerListener(javax.jms.MessageListener listener)
                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

requestResponseToCSHost

MessageObject requestResponseToCSHost(MessageObject obj,
                                    UUID correlationId,
                                    UUID hostId)
                                      throws javax.jms.JMSException,
                                             TimeoutException

Throws:

javax.jms.JMSException

TimeoutException

requestResponseToCSHost

MessageObject requestResponseToCSHost(MessageObject obj,
                                    UUID correlationId,
                                    UUID hostId,
                                    CancellationToken cancelToken)
                                      throws javax.jms.JMSException,
                                             TimeoutException

Throws:

javax.jms.JMSException

TimeoutException

requestResponse

MessageObject requestResponse(MessageObject obj,
                            UUID correlationId)
                              throws javax.jms.JMSException,
                                     TimeoutException

Throws:

javax.jms.JMSException

TimeoutException

requestResponse

MessageObject requestResponse(MessageObject obj,
                            UUID correlationId,
                            CancellationToken cancelToken)
                              throws javax.jms.JMSException,
                                     TimeoutException

Throws:

javax.jms.JMSException

TimeoutException

oneway

void oneway(MessageObject obj)
            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

oneway

void oneway(MessageObject obj,
          UUID correlationId)
            throws javax.jms.JMSException

Throws:

javax.jms.JMSException

onewayToCSHost

void onewayToCSHost(MessageObject obj,
                  UUID correlationId,
                  UUID hostId)
                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

respond

void respond(MessageObject obj,
           javax.jms.Destination dest,
           UUID correlationId)
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

respond

void respond(MessageObject obj,
           javax.jms.Destination dest)
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException