Package com.netlang.queue

Class NQQueue

java.lang.Object

com.netlang.queue.NQQueue

public class NQQueue
extends Object

The SQLQuery class

Constructor Summary

Constructors

Constructor	Description
NQQueue(String name, boolean persistent, NQManager con, com.netlang.queue.impl.QConnection qcon, com.netlang.session.NetlangSession session, String handleid, String resourceid, String agentid, boolean topic)	Initializes a newly created SQLQuery
NQQueue(String name, com.netlang.queue.impl.QConnection qcon, boolean topic)	Initializes a newly created SQLQuery

Method Summary

Modifier and Type	Method	Description
void	close()
NQMessage	get(long timeout)
NQMessage	getAndClear(long timeout)
NQMessage	getById(String id, long timeout)
NQMessage	getResponse(NQMessage message, long timeout)
NQMessage	getResponse(String id, long timeout)
String	getText(long timeout)
String	getTextAndClear(long timeout)
void	open()	Open file
void	purge()
NQMessage	put(NQMessage message, boolean wantResponse, String responseQueue, boolean waitForResponse, long timeout)
void	putResponse(NQMessage responseToMessage, NQMessage message)
void	putResponseText(NQMessage responseToMessage, String text)
NQMessage	putText(String text, boolean wantResponse, String responseQueue, boolean waitForResponse, long timeout)
NQQuery	query()	Query the queue, the query does not remove messages

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NQQueue

public NQQueue(String name,
 com.netlang.queue.impl.QConnection qcon,
 boolean topic)
        throws com.net4z.APIException

Initializes a newly created SQLQuery

Throws:

com.net4z.APIException

NQQueue

public NQQueue(String name,
 boolean persistent,
 NQManager con,
 com.netlang.queue.impl.QConnection qcon,
 com.netlang.session.NetlangSession session,
 String handleid,
 String resourceid,
 String agentid,
 boolean topic)
        throws com.net4z.APIException

Initializes a newly created SQLQuery

Throws:

com.net4z.APIException

Method Details

open

public void open()
          throws com.net4z.APIException

Open file

Throws:

com.net4z.APIException

putText

public NQMessage putText(String text,
 boolean wantResponse,
 String responseQueue,
 boolean waitForResponse,
 long timeout)
                  throws com.net4z.APIException

Throws:

com.net4z.APIException

put

public NQMessage put(NQMessage message,
 boolean wantResponse,
 String responseQueue,
 boolean waitForResponse,
 long timeout)
              throws com.net4z.APIException

Throws:

com.net4z.APIException

putResponse

public void putResponse(NQMessage responseToMessage,
 NQMessage message)
                 throws com.net4z.APIException

Throws:

com.net4z.APIException

putResponseText

public void putResponseText(NQMessage responseToMessage,
 String text)
                     throws com.net4z.APIException

Throws:

com.net4z.APIException

getResponse

public NQMessage getResponse(String id,
 long timeout)
                      throws com.net4z.APIException

Throws:

com.net4z.APIException

getResponse

public NQMessage getResponse(NQMessage message,
 long timeout)
                      throws com.net4z.APIException

Throws:

com.net4z.APIException

query

public NQQuery query()
              throws Exception

Query the queue, the query does not remove messages

Throws:

Exception

getById

public NQMessage getById(String id,
 long timeout)
                  throws com.net4z.APIException

Throws:

com.net4z.APIException

getText

public String getText(long timeout)
               throws com.net4z.APIException

Throws:

com.net4z.APIException

getTextAndClear

public String getTextAndClear(long timeout)
                       throws com.net4z.APIException

Throws:

com.net4z.APIException

get

public NQMessage get(long timeout)
              throws com.net4z.APIException

Throws:

com.net4z.APIException

getAndClear

public NQMessage getAndClear(long timeout)
                      throws com.net4z.APIException

Throws:

com.net4z.APIException

purge

public void purge()
           throws com.net4z.APIException

Throws:

com.net4z.APIException

close

public void close()
           throws com.net4z.APIException

Throws:

com.net4z.APIException