18#ifndef ACTIVEMQ_TRANSPORT_TRANSPORT_H_
19#define ACTIVEMQ_TRANSPORT_TRANSPORT_H_
46 using decaf::lang::Pointer;
47 using activemq::commands::Command;
48 using activemq::commands::Response;
#define AMQCPP_API
Definition Config.h:30
Interface for a transport layer for command objects.
Definition Transport.h:60
virtual bool isFaultTolerant() const =0
Is this Transport fault tolerant, meaning that it will reconnect to a broker on disconnect.
virtual void reconnect(const decaf::net::URI &uri)=0
reconnect to another location
virtual Pointer< Response > request(const Pointer< Command > command)=0
Sends the given command to the broker and then waits for the response.
virtual Pointer< FutureResponse > asyncRequest(const Pointer< Command > command, const Pointer< ResponseCallback > responseCallback)=0
Sends a commands asynchronously, returning a FutureResponse object that the caller can use to check t...
virtual bool isReconnectSupported() const =0
virtual Pointer< Response > request(const Pointer< Command > command, unsigned int timeout)=0
Sends the given command to the broker and then waits for the response.
virtual void start()=0
Starts the Transport, the send methods of a Transport will throw an exception if used before the Tran...
virtual Transport * narrow(const std::type_info &typeId)=0
Narrows down a Chain of Transports to a specific Transport to allow a higher level transport to skip ...
virtual void updateURIs(bool rebalance, const decaf::util::List< decaf::net::URI > &uris)=0
Updates the set of URIs the Transport can connect to.
virtual Pointer< wireformat::WireFormat > getWireFormat() const =0
Gets the WireFormat instance that is in use by this transport.
virtual std::string getRemoteAddress() const =0
virtual bool isUpdateURIsSupported() const =0
virtual void setTransportListener(TransportListener *listener)=0
Sets the observer of asynchronous events from this transport.
virtual bool isConnected() const =0
Is the Transport Connected to its Broker.
virtual TransportListener * getTransportListener() const =0
Gets the observer of asynchronous events from this transport.
virtual void stop()=0
Stops the Transport.
virtual bool isClosed() const =0
Has the Transport been shutdown and no longer usable.
virtual void setWireFormat(const Pointer< wireformat::WireFormat > wireFormat)=0
Sets the WireFormat instance to use.
virtual void oneway(const Pointer< Command > command)=0
Sends a one-way command.
A listener of asynchronous exceptions from a command transport object.
Definition TransportListener.h:38
Base interface for all classes that run as a Service inside the application.
Definition Service.h:31
Interface for a class that implements the close method.
Definition Closeable.h:30
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
This class represents an instance of a URI as defined by RFC 2396.
Definition URI.h:37
An ordered collection (also known as a sequence).
Definition List.h:47
Definition AbstractTransportFactory.h:30
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24