Package org.netxms.base

Class NXCPMsgWaitQueue

java.lang.Object

org.netxms.base.NXCPMsgWaitQueue

public class NXCPMsgWaitQueue
extends Object

NXCP message wait queue

Constructor Summary

Constructors

Constructor	Description
NXCPMsgWaitQueue(int defaultTimeout)	Create message wait queue with default message lifetime (60 seconds).
NXCPMsgWaitQueue(int defaultTimeout, int messageLifeTime)	Create message wait queue.

Method Summary

Modifier and Type	Method	Description
int	getDefaultTimeout()	Get queue's default wait timeout
void	putMessage(NXCPMessage msg)	Put message into queue.
void	shutdown()	Shutdown wait queue.
String	toString()
NXCPMessage	waitForMessage(int code, long id)	Wait for message using default wait timeout.
NXCPMessage	waitForMessage(int code, long id, int timeout)	Wait for message.

Methods inherited from class java.lang.Object

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

Constructor Details

NXCPMsgWaitQueue

public NXCPMsgWaitQueue(int defaultTimeout,
 int messageLifeTime)

Create message wait queue.

Parameters:

defaultTimeout - default wait timeout in milliseconds

messageLifeTime - message lifetime in milliseconds

NXCPMsgWaitQueue

public NXCPMsgWaitQueue(int defaultTimeout)

Create message wait queue with default message lifetime (60 seconds).

Parameters:

defaultTimeout - default wait timeout in milliseconds

Method Details

putMessage

public void putMessage(NXCPMessage msg)

Put message into queue.

Parameters:

msg - NXCP message

waitForMessage

public NXCPMessage waitForMessage(int code,
 long id,
 int timeout)

Wait for message.

Parameters:

code - Message code

id - Message id

timeout - Wait timeout in milliseconds

Returns:

received NXCP message or null if message was not received before timeout

waitForMessage

public NXCPMessage waitForMessage(int code,
 long id)

Wait for message using default wait timeout.

Parameters:

code - Message code

id - Message id

Returns:

received NXCP message or null if message was not received before timeout

shutdown

public void shutdown()

Shutdown wait queue.

getDefaultTimeout

public int getDefaultTimeout()

Get queue's default wait timeout

Returns:

default wait timeout in milliseconds

toString

public String toString()

Overrides:

toString in class Object

See Also:

• Object.toString()