Package com.softwaremining.mq

Class MQManager

java.lang.Object

com.softwaremining.mq.MQManager

public class MQManager
extends Object

MQManager has the responsibility to provide access to a user defined MQImplementation.
by default the system uses com.softwaremining.mq.MQImpl - which is based on ActiveMQ
You can override this by setting the following in softwaremining.properties:
MQ_IMPL=com.mycompany.MyMqImplementation
This HAS TO implement the interface
com.softwaremining.mq.MQInterface

Constructor Summary

Constructors

Constructor	Description
MQManager()

Method Summary

Modifier and Type	Method	Description
static int	close(IBaseService baseService, double hcConn, ISMDataType handleObj, double options, ISMNumeric completionCode, ISMNumeric reason)
static int	connect(IBaseService baseService, ISMNumeric hcConn, ISMNumeric completionCode, ISMNumeric reason)
static int	connect(IBaseService baseService, String queueManager, ISMNumeric hcConn, ISMNumeric completionCode, ISMNumeric reason)
static int	disconnect(IBaseService baseService, long hcConn, ISMNumeric completionCode, ISMNumeric reason)
static int	get(IBaseService baseService, long hcConn, long hObj, ISMDataType queueObjectName, ISMDataType msgOpts, long bufferLength, ISMDataType buffer, ISMNumeric dataLength, ISMNumeric completionCode, ISMNumeric reason)
static int	get(IBaseService baseService, long hcConn, ISMDouble hObj, ISMDataType queueObjectName, ISMDataType msgOpts, long bufferLength, ISMDataType buffer, ISMNumeric dataLength, ISMNumeric completionCode, ISMNumeric reason)
static MQInterface	getImplementation()
static int	open(IBaseService baseService, double hcConn, ISMDataType queueObjectName, double options, double objRequestq, ISMNumeric completionCode, ISMNumeric reason)
static int	put(IBaseService baseService, long hcConn, long hObj, ISMDataType queueObjectName, ISMDataType msgOpts, long bufferLength, String buffer, ISMNumeric completionCode, ISMNumeric reason)

Methods inherited from class java.lang.Object

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

Constructor Details

MQManager

public MQManager()

Method Details

getImplementation

public static MQInterface getImplementation()

connect

public static int connect(IBaseService baseService,
 String queueManager,
 ISMNumeric hcConn,
 ISMNumeric completionCode,
 ISMNumeric reason)

connect

public static int connect(IBaseService baseService,
 ISMNumeric hcConn,
 ISMNumeric completionCode,
 ISMNumeric reason)

open

public static int open(IBaseService baseService,
 double hcConn,
 ISMDataType queueObjectName,
 double options,
 double objRequestq,
 ISMNumeric completionCode,
 ISMNumeric reason)

close

public static int close(IBaseService baseService,
 double hcConn,
 ISMDataType handleObj,
 double options,
 ISMNumeric completionCode,
 ISMNumeric reason)

get

public static int get(IBaseService baseService,
 long hcConn,
 long hObj,
 ISMDataType queueObjectName,
 ISMDataType msgOpts,
 long bufferLength,
 ISMDataType buffer,
 ISMNumeric dataLength,
 ISMNumeric completionCode,
 ISMNumeric reason)

get

public static int get(IBaseService baseService,
 long hcConn,
 ISMDouble hObj,
 ISMDataType queueObjectName,
 ISMDataType msgOpts,
 long bufferLength,
 ISMDataType buffer,
 ISMNumeric dataLength,
 ISMNumeric completionCode,
 ISMNumeric reason)

put

public static int put(IBaseService baseService,
 long hcConn,
 long hObj,
 ISMDataType queueObjectName,
 ISMDataType msgOpts,
 long bufferLength,
 String buffer,
 ISMNumeric completionCode,
 ISMNumeric reason)

disconnect

public static int disconnect(IBaseService baseService,
 long hcConn,
 ISMNumeric completionCode,
 ISMNumeric reason)