Package com.wombat.mama
Class MamaTransport
- java.lang.Object
-
- com.wombat.mama.MamaTransport
-
public class MamaTransport extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description MamaTransport()
The constructor initialises all member variables and creates the re-usable objects including the transport listeners.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
_create(MamaBridge bridge)
void
_create(java.lang.String name, MamaBridge bridge)
void
addTransportListener(MamaTransportListener transportListener)
This function will set the client listener, note that only one listener or extended listener is supported at any one time.void
addTransportTopicListener(MamaTransportTopicListener transportTopicListener)
This function will set the client topic listener, note that only one topic listener is supported at any one time.void
create(MamaBridge bridge)
void
create(java.lang.String name, MamaBridge bridge)
void
destroy()
MamaBridge
getBridge()
java.lang.String
getDescription()
boolean
getInvokeQualityForAllSubscs()
java.lang.String
getName()
double
getOutboundThrottle()
double
getOutboundThrottle(MamaThrottleInstance throttleInstance)
long
getPointerVal()
short
getQuality()
void
removeTransportListener(MamaTransportListener transportListener)
This function will remove the current transport listener.void
removeTransportTopicListener()
This function will remove the current topic listener.void
requestConflation()
void
requestEndConflation()
void
setDescription(java.lang.String description)
void
setInvokeQualityForAllSubscs(boolean invokeQualityForAllSubscs)
void
setName(java.lang.String name)
void
setOutboundThrottle(double outboundThrottle)
void
setOutboundThrottle(MamaThrottleInstance throttleInstance, double outboundThrottle)
-
-
-
Method Detail
-
addTransportListener
public void addTransportListener(MamaTransportListener transportListener)
This function will set the client listener, note that only one listener or extended listener is supported at any one time.
-
addTransportTopicListener
public void addTransportTopicListener(MamaTransportTopicListener transportTopicListener)
This function will set the client topic listener, note that only one topic listener is supported at any one time.
-
removeTransportListener
public void removeTransportListener(MamaTransportListener transportListener)
This function will remove the current transport listener. It will actually remove both the basic and extended listeners.
-
removeTransportTopicListener
public void removeTransportTopicListener()
This function will remove the current topic listener.
-
getPointerVal
public long getPointerVal()
-
create
public void create(MamaBridge bridge)
-
_create
public void _create(MamaBridge bridge)
-
create
public void create(java.lang.String name, MamaBridge bridge)
-
_create
public void _create(java.lang.String name, MamaBridge bridge)
-
destroy
public void destroy()
-
getOutboundThrottle
public double getOutboundThrottle(MamaThrottleInstance throttleInstance)
-
getOutboundThrottle
public double getOutboundThrottle()
-
setOutboundThrottle
public void setOutboundThrottle(MamaThrottleInstance throttleInstance, double outboundThrottle)
-
setOutboundThrottle
public void setOutboundThrottle(double outboundThrottle)
-
setDescription
public void setDescription(java.lang.String description)
-
getDescription
public java.lang.String getDescription()
-
setInvokeQualityForAllSubscs
public void setInvokeQualityForAllSubscs(boolean invokeQualityForAllSubscs)
-
getInvokeQualityForAllSubscs
public boolean getInvokeQualityForAllSubscs()
-
getQuality
public short getQuality()
-
getBridge
public MamaBridge getBridge()
-
requestConflation
public void requestConflation()
-
requestEndConflation
public void requestEndConflation()
-
getName
public java.lang.String getName()
-
setName
public void setName(java.lang.String name)
-
-