Examples of registerQueue()

Examples of backtype.storm.messaging.IConnection.registerQueue()

142
143
144
145
146
147
148
149
150
151
152
    IContext context = workerData.getContext();
    String topologyId = workerData.getTopologyId();

    IConnection recvConnection = context.bind(topologyId,
        workerData.getPort());
    recvConnection.registerQueue(recvQueue);

    RunnableCallback recvDispather = new VirtualPortDispatch(workerData,
        recvConnection, recvQueue);

    AsyncLoopThread vthread = new AsyncLoopThread(recvDispather, false,
View Full Code Here

Examples of backtype.storm.messaging.IConnection.registerQueue()

220
221
222
223
224
225
226
227
228
229
230
    WaitStrategy waitStrategy = (WaitStrategy) Utils
        .newInstance((String) storm_conf
            .get(Config.TOPOLOGY_DISRUPTOR_WAIT_STRATEGY));
    DisruptorQueue recvQueue = new DisruptorQueue(
        "NettyUnitTest", ProducerType.SINGLE, 1024, waitStrategy);
    server.registerQueue(recvQueue);

    TaskMessage recv = server.recv(0);
    Assert.assertEquals(req_msg, new String(recv.message()));

    lock.lock();
View Full Code Here

Examples of backtype.storm.messaging.IConnection.registerQueue()

249
250
251
252
253
254
255
256
257
258
259
    WaitStrategy waitStrategy = (WaitStrategy) Utils
        .newInstance((String) storm_conf
            .get(Config.TOPOLOGY_DISRUPTOR_WAIT_STRATEGY));
    DisruptorQueue recvQueue = new DisruptorQueue(
        "NettyUnitTest", ProducerType.SINGLE, 1024, waitStrategy);
    server.registerQueue(recvQueue);


    new Thread(new Runnable() {
       
        public void send() {
View Full Code Here

Examples of backtype.storm.messaging.IConnection.registerQueue()

331
332
333
334
335
336
337
338
339
340
341
    WaitStrategy waitStrategy = (WaitStrategy) Utils
        .newInstance((String) storm_conf
            .get(Config.TOPOLOGY_DISRUPTOR_WAIT_STRATEGY));
    DisruptorQueue recvQueue = new DisruptorQueue(
        "NettyJunitTest", ProducerType.SINGLE, 4, waitStrategy);
    server.registerQueue(recvQueue);


    new Thread(new Runnable() {

      @Override
View Full Code Here

Examples of backtype.storm.messaging.IConnection.registerQueue()

419
420
421
422
423
424
425
426
427
428
429
    WaitStrategy waitStrategy = (WaitStrategy) Utils
        .newInstance((String) storm_conf
            .get(Config.TOPOLOGY_DISRUPTOR_WAIT_STRATEGY));
    DisruptorQueue recvQueue = new DisruptorQueue(
        "NettyJunitTest", ProducerType.SINGLE, 4, waitStrategy);
    server.registerQueue(recvQueue);

    new Thread(new Runnable() {

      @Override
      public void run() {
View Full Code Here

Examples of backtype.storm.messaging.IConnection.registerQueue()

533
534
535
536
537
538
539
540
541
542
543
    WaitStrategy waitStrategy = (WaitStrategy) Utils
        .newInstance((String) storm_conf
            .get(Config.TOPOLOGY_DISRUPTOR_WAIT_STRATEGY));
    DisruptorQueue recvQueue = new DisruptorQueue(
        "NettyUnitTest", ProducerType.SINGLE, 1024, waitStrategy);
    server.registerQueue(recvQueue);

    TaskMessage recv = server.recv(0);
    System.out.println("Sever receive first");
    Assert.assertEquals(req_msg, new String(recv.message()));
View Full Code Here

Examples of backtype.storm.messaging.IConnection.registerQueue()

621
622
623
624
625
626
627
628
629
630
631
    System.out.println("!!shutdow server and sleep 30s, please wait!!");
    Thread.sleep(30000);

    IConnection server2 = context.bind(null, port);
    server2.registerQueue(recvQueue);
    System.out.println("!!!!!!!!!!!!!!!!!!!! restart server !!!!!!!!!!!");

    TaskMessage recv2 = server2.recv(0);
    Assert.assertEquals(req_msg, new String(recv2.message()));
View Full Code Here

Examples of org.ajax4jsf.component.QueueRegistry.registerQueue()

100
101
102
103
104
105
106
107
108
109
110
      if (queueRegistry.isShouldCreateDefaultGlobalQueue()) {
        String encodedGlobalQueueName = context.getExternalContext().encodeNamespace(
            UIQueue.GLOBAL_QUEUE_NAME);
       
        if (!queueRegistry.containsQueue(encodedGlobalQueueName)) {
          queueRegistry.registerQueue(context, encodedGlobalQueueName, null);
        }
      }

      if (queueRegistry.hasQueuesToEncode()) {
        super.encode(resource, context, queueRegistry.getRegisteredQueues(context), attributes);
View Full Code Here

Examples of org.apache.qpid.server.exchange.Exchange.registerQueue()

203
204
205
206
207
208
209
210
211
212
213
                if (defaultExchange == null)
                {
                    throw new ConfigurationException("Attempt to bind queue to unknown exchange:" + binding);
                }

                defaultExchange.registerQueue(queue.getName(), queue, null);

                if (binding.getRoutingKey() == null || binding.getRoutingKey().equals(""))
                {
                    throw new ConfigurationException("Unknown binding not specified on url:" + binding);
                }
View Full Code Here

Examples of org.apache.qpid.server.exchange.Exchange.registerQueue()

80
81
82
83
84
85
86
87
88
89
90
        final Exchange exch = exchangeRegistry.getExchange(body.exchange);
        if (exch == null)
        {
            throw body.getChannelException(AMQConstant.NOT_FOUND.getCode(), "Exchange " + body.exchange + " does not exist.");
        }
        exch.registerQueue(body.routingKey, queue, body.arguments);
        queue.bind(body.routingKey, exch);
        if (_log.isInfoEnabled())
        {
            _log.info("Binding queue " + queue + " to exchange " + exch + " with routing key " + body.routingKey);
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.