Package com.netlang.queue

Class NQManager

java.lang.Object

com.netlang.queue.NQManager

public class NQManager
extends Object

Manager for connection to Netlang Queue Services.

Example of usage

		NQManager manager = new NQManager("my_resource",false);
		NQQueue queue1 = manager.connectQueue("testqueue",false);
		queue1.putText("Hello World on Queue",false,null,false,3000l);
		queue1.close();
		manager.close();
  

Constructor Summary

Constructors

Constructor	Description
NQManager()	Initializes a newly created NQManaager
NQManager(com.netlang.session.NetlangSession session, String resourceid, boolean pooled)	Initializes a newly created XQManager
NQManager(com.netlang.session.NetlangSession session, String server, int port, String user, String password, boolean pooled)	Initializes a newly created XQManager
NQManager(String resourceid, boolean pooled)	Initializes a newly created XQManager
NQManager(String server, int port, String user, String password, boolean pooled)	Initializes a newly created XQManager

Method Summary

Modifier and Type	Method	Description
void	begin()	Transaction begin
void	close()
void	commit()	Transaction commit
NQQueue	connectQueue(String name, boolean persistent)	Query
NQQueue	connectTopic(String name, boolean persistent)	Query
NQMessage	createMessage()
void	open()	Open file
void	rollback()	Transaction rollback
void	transaction(int mode)	Transaction

Methods inherited from class java.lang.Object

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

Constructor Details

NQManager

public NQManager(String resourceid,
 boolean pooled)
          throws com.net4z.APIException

Initializes a newly created XQManager

Throws:

com.net4z.APIException

NQManager

public NQManager(String server,
 int port,
 String user,
 String password,
 boolean pooled)
          throws Exception

Initializes a newly created XQManager

Parameters:

server - - the server address

Throws:

Exception

NQManager

public NQManager(com.netlang.session.NetlangSession session,
 String server,
 int port,
 String user,
 String password,
 boolean pooled)
          throws Exception

Initializes a newly created XQManager

Parameters:

server - - the server address

Throws:

Exception

NQManager

public NQManager(com.netlang.session.NetlangSession session,
 String resourceid,
 boolean pooled)
          throws com.net4z.APIException

Initializes a newly created XQManager

Throws:

com.net4z.APIException

NQManager

public NQManager()

Initializes a newly created NQManaager

Method Details

open

public void open()
          throws com.net4z.APIException

Open file

Throws:

com.net4z.APIException

begin

public void begin()
           throws com.net4z.APIException

Transaction begin

Throws:

com.net4z.APIException

commit

public void commit()
            throws com.net4z.APIException

Transaction commit

Throws:

com.net4z.APIException

rollback

public void rollback()
              throws com.net4z.APIException

Transaction rollback

Throws:

com.net4z.APIException

transaction

public void transaction(int mode)
                 throws com.net4z.APIException

Transaction

Throws:

com.net4z.APIException

connectQueue

public NQQueue connectQueue(String name,
 boolean persistent)
                     throws com.net4z.APIException

Query

Throws:

Exception

com.net4z.APIException

connectTopic

public NQQueue connectTopic(String name,
 boolean persistent)
                     throws com.net4z.APIException

Query

Throws:

Exception

com.net4z.APIException

close

public void close()
           throws com.net4z.APIException

Throws:

com.net4z.APIException

createMessage

public NQMessage createMessage()
                        throws com.net4z.APIException

Throws:

com.net4z.APIException