本文整理了Java中org.objectweb.joram.client.jms.Queue.create
方法的一些代码示例,展示了Queue.create
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.create
方法的具体详情如下:
包路径:org.objectweb.joram.client.jms.Queue
类名称:Queue
方法名:create
[英]Administration method creating and deploying a queue on the local server.
The request fails if the destination deployment fails server side.
Be careful this method use the static AdminModule connection.
[中]在本地服务器上创建和部署队列的管理方法。
如果目标部署在服务器端失败,请求将失败。
注意,这种方法使用静态AdminModule连接。
代码示例来源:origin: org.ow2.joram/joram-client-jms
/**
* Administration method creating and deploying a queue on a given server.
* It creates a Joram's standard queue.
* <p>
* The request fails if the target server does not belong to the platform,
* or if the destination deployment fails server side.
* <p>
* Be careful this method use the static AdminModule connection.
*
* @param serverId The identifier of the server where deploying the queue.
* @param prop The queue properties.
*
* @exception ConnectException If the admin connection is closed or broken.
* @exception AdminException If the request fails.
*/
public static Queue create(int serverId, Properties prop) throws ConnectException, AdminException {
return create(serverId, null, prop);
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
/**
* Administration method creating and deploying a queue on a given server.
* <p>
* The request fails if the target server does not belong to the platform,
* or if the destination deployment fails server side.
* <p>
* Be careful this method use the static AdminModule connection.
*
* @param serverId The identifier of the server where deploying the queue.
*
* @exception ConnectException If the admin connection is closed or broken.
* @exception AdminException If the request fails.
*/
public static Queue create(int serverId) throws ConnectException, AdminException {
return create(serverId, null, null, null);
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
/**
* Administration method creating and deploying (or retrieving) a queue on a given
* server with a given name. First a destination with the specified name is
* searched on the given server, if it does not exist it is created. In any
* case, its provider-specific address is returned.
* <p>
* The request fails if the target server does not belong to the platform,
* or if the destination deployment fails server side.
* <p>
* Be careful this method use the static AdminModule connection.
*
* @param serverId The identifier of the server where deploying the queue.
* @param name The queue name.
*
* @exception ConnectException If the admin connection is closed or broken.
* @exception AdminException If the request fails.
*/
public static Queue create(int serverId, String name) throws ConnectException, AdminException {
return create(serverId, name, null, null);
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
/**
* Administration method creating and deploying a scheduled queue on a given server.
* <p>
* The request fails if the target server does not belong to the platform,
* or if the destination deployment fails server side.
* <p>
* Be careful this method use the static AdminModule connection.
*
* @param serverId The identifier of the server where deploying the queue.
* @param name The name of the created queue.
* @return the created destination.
*
* @exception ConnectException If the administration connection is closed or broken.
* @exception AdminException If the request fails.
*/
public static Queue create(int serverId,
String name) throws ConnectException, AdminException {
Queue queue = Queue.create(serverId, name, Queue.SCHEDULER_QUEUE, null);
return queue;
}
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
/**
* Administration method creating and deploying a queue on a given server.
* <p>
* The request fails if the target server does not belong to the platform,
* or if the destination deployment fails server side.
* <p>
* Be careful this method use the static AdminModule connection.
*
* @param serverId The identifier of the server where deploying the queue.
* @param className The queue class name.
* @param prop The queue properties.
*
* @exception ConnectException If the admin connection is closed or broken.
* @exception AdminException If the request fails.
*/
public static Queue create(int serverId,
String className,
Properties prop) throws ConnectException, AdminException {
return create(serverId, null, className, prop);
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
/**
* Administration method creating and deploying a queue on the local server.
* <p>
* The request fails if the destination deployment fails server side.
* <p>
* Be careful this method use the static AdminModule connection.
*
* @exception ConnectException If the admin connection is closed or broken.
* @exception AdminException If the request fails.
*/
public static Queue create() throws ConnectException, AdminException {
return create(AdminModule.getLocalServerId());
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
props = new Properties();
props.setProperty("distribution.className", MailDistribution);
Queue queue = Queue.create(serverId, name, Queue.DISTRIBUTION_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
props = new Properties();
props.setProperty("acquisition.className", MailAcquisition);
Queue queue = Queue.create(serverId, name, Queue.ACQUISITION_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
props = new Properties();
props.setProperty("acquisition.className", JMXAcquisition);
Queue queue = Queue.create(serverId, name, Queue.ACQUISITION_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
/**
* Administration method creating and deploying (or retrieving) a queue on the
* local server. First a destination with the specified name is searched
* on the given server, if it does not exist it is created. In any case,
* its provider-specific address is returned.
* <p>
* The request fails if the destination deployment fails server side.
* <p>
* Be careful this method use the static AdminModule connection.
*
* @param name The queue name.
*
* @exception ConnectException If the admin connection is closed or broken.
* @exception AdminException If the request fails.
*/
public static Queue create(String name) throws ConnectException, AdminException {
return create(AdminModule.getLocalServerId(), name, null, null);
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
props.setProperty("distribution.className", AMQPDistribution);
props.setProperty("amqp.QueueName", dest);
Queue queue = Queue.create(serverId, name, Queue.DISTRIBUTION_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
if (!props.containsKey("ftpImplName"))
props.setProperty("ftpImplName", DefaultFTPImpl);
Queue queue = Queue.create(serverId, name, Queue.FTP_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
props.setProperty("acquisition.className", URLAcquisition);
props.setProperty("collector.url", url);
Queue queue = Queue.create(serverId, name, Queue.ACQUISITION_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
props.setProperty("distribution.className", JMSDistribution);
props.setProperty("jms.DestinationName", dest);
Queue queue = Queue.create(serverId, name, Queue.DISTRIBUTION_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
props.setProperty("acquisition.className", JMSAcquisition);
props.setProperty("jms.DestinationName", dest);
Queue queue = Queue.create(serverId, name, Queue.ACQUISITION_QUEUE, props);
return queue;
代码示例来源:origin: org.ow2.joram/joram-client-jms
props.setProperty("acquisition.className", AMQPAcquisition);
props.setProperty("amqp.QueueName", dest);
Queue queue = Queue.create(serverId, name, Queue.ACQUISITION_QUEUE, props);
return queue;
代码示例来源:origin: org.objectweb.petals/petals-kernel
/**
* Create a new queue
*
* @param queueName
* the name of the queue to be created
* @see Topic#create()
*/
public Queue createQueue(String queueName) throws ConnectException,
AdminException {
Queue queue = Queue.create(queueName);
queue.setFreeReading();
queue.setFreeWriting();
return queue;
}
代码示例来源:origin: org.ow2.joram/joram-client-jms
return Queue.create(serverId, name, Destination.DISTRIBUTION_QUEUE, props);
代码示例来源:origin: org.ow2.joram/joram-client-jms
return Queue.create(serverId, name, Destination.ACQUISITION_QUEUE, props);
代码示例来源:origin: org.objectweb.jonas/jonas-jms-manager
/**
* Create a Queue and bind it to the registry
*/
public Queue createQueue(String name) throws Exception {
TraceJms.logger.log(BasicLevel.DEBUG,"");
org.objectweb.joram.client.jms.Queue queue = null;
try {
queue = (org.objectweb.joram.client.jms.Queue) ictx.lookup(name);
} catch (Exception e) {
queue = org.objectweb.joram.client.jms.Queue.create(name);
ictx.rebind(name, queue);
}
queue.setWriter(user);
queue.setReader(user);
queue.setWriter(jonasUser);
queue.setReader(jonasUser);
return queue;
}
内容来源于网络,如有侵权,请联系作者删除!