org.apache.qpid.proton.messenger.impl

Class MessengerImpl

java.lang.Object

org.apache.qpid.proton.messenger.impl.MessengerImpl

All Implemented Interfaces:

Messenger

public class MessengerImpl
extends java.lang.Object
implements Messenger

Field Summary

Fields inherited from interface org.apache.qpid.proton.messenger.Messenger

CUMULATIVE

Constructor Summary

Constructors

Constructor and Description
MessengerImpl() Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a MessengerFactory instead
MessengerImpl(java.lang.String name) Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a MessengerFactory instead

Method Summary

Methods

Modifier and Type	Method and Description
void	accept(Tracker tracker, int flags)
Message	get()
int	getIncomingWindow()
int	getOutgoingWindow()
Status	getStatus(Tracker tracker)
long	getTimeout()
int	incoming()
Tracker	incomingTracker()
void	interrupt()
boolean	isBlocking()
int	outgoing()
Tracker	outgoingTracker()
void	put(Message m)
int	receiving()
void	recv()
void	recv(int n)
void	reject(Tracker tracker, int flags)
void	rewrite(java.lang.String pattern, java.lang.String address)
void	route(java.lang.String pattern, java.lang.String address)
void	send()
void	send(int n)
void	setBlocking(boolean b)
void	setIncomingWindow(int window)
void	setOutgoingWindow(int window)
void	setTimeout(long timeInMillis)
void	settle(Tracker tracker, int flags)
void	start()
void	stop()
boolean	stopped()
void	subscribe(java.lang.String source)
java.lang.String	toString()
boolean	work(long timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MessengerImpl

@Deprecated
public MessengerImpl()

Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a MessengerFactory instead

MessengerImpl

@Deprecated
public MessengerImpl(java.lang.String name)

Deprecated. This constructor's visibility will be reduced to the default scope in a future release. Client code outside this module should use a MessengerFactory instead

Method Detail

setTimeout

public void setTimeout(long timeInMillis)

Specified by:

setTimeout in interface Messenger

getTimeout

public long getTimeout()

Specified by:

getTimeout in interface Messenger

isBlocking

public boolean isBlocking()

Specified by:

isBlocking in interface Messenger

setBlocking

public void setBlocking(boolean b)

Specified by:

setBlocking in interface Messenger

start

public void start()
           throws java.io.IOException

Specified by:

start in interface Messenger

Throws:

java.io.IOException

stop

public void stop()

Specified by:

stop in interface Messenger

stopped

public boolean stopped()

Specified by:

stopped in interface Messenger

work

public boolean work(long timeout)
             throws TimeoutException

Specified by:

work in interface Messenger

Throws:

TimeoutException

interrupt

public void interrupt()

Specified by:

interrupt in interface Messenger

put

public void put(Message m)
         throws MessengerException

Specified by:

put in interface Messenger

Throws:

MessengerException

send

public void send()
          throws TimeoutException

Specified by:

send in interface Messenger

Throws:

TimeoutException

send

public void send(int n)
          throws TimeoutException

Specified by:

send in interface Messenger

Throws:

TimeoutException

recv

public void recv(int n)
          throws TimeoutException

Specified by:

recv in interface Messenger

Throws:

TimeoutException

recv

public void recv()
          throws TimeoutException

Specified by:

recv in interface Messenger

Throws:

TimeoutException

receiving

public int receiving()

Specified by:

receiving in interface Messenger

get

public Message get()

Specified by:

get in interface Messenger

subscribe

public void subscribe(java.lang.String source)
               throws MessengerException

Specified by:

subscribe in interface Messenger

Throws:

MessengerException

outgoing

public int outgoing()

Specified by:

outgoing in interface Messenger

incoming

public int incoming()

Specified by:

incoming in interface Messenger

getIncomingWindow

public int getIncomingWindow()

Specified by:

getIncomingWindow in interface Messenger

setIncomingWindow

public void setIncomingWindow(int window)

Specified by:

setIncomingWindow in interface Messenger

getOutgoingWindow

public int getOutgoingWindow()

Specified by:

getOutgoingWindow in interface Messenger

setOutgoingWindow

public void setOutgoingWindow(int window)

Specified by:

setOutgoingWindow in interface Messenger

incomingTracker

public Tracker incomingTracker()

Specified by:

incomingTracker in interface Messenger

outgoingTracker

public Tracker outgoingTracker()

Specified by:

outgoingTracker in interface Messenger

reject

public void reject(Tracker tracker,
          int flags)

Specified by:

reject in interface Messenger

accept

public void accept(Tracker tracker,
          int flags)

Specified by:

accept in interface Messenger

settle

public void settle(Tracker tracker,
          int flags)

Specified by:

settle in interface Messenger

getStatus

public Status getStatus(Tracker tracker)

Specified by:

getStatus in interface Messenger

route

public void route(java.lang.String pattern,
         java.lang.String address)

Specified by:

route in interface Messenger

rewrite

public void rewrite(java.lang.String pattern,
           java.lang.String address)

Specified by:

rewrite in interface Messenger

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object