org.objectweb.joram.client.jms.Queue.create()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.2k)|赞(0)|评价(0)|浏览(68)

本文整理了Java中org.objectweb.joram.client.jms.Queue.create方法的一些代码示例,展示了Queue.create的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.create方法的具体详情如下:
包路径:org.objectweb.joram.client.jms.Queue
类名称:Queue
方法名:create

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;
}

相关文章

微信公众号

最新文章

更多