Package org.apache.qpid.framing

Examples of org.apache.qpid.framing.AMQShortString.asString()

360
361
362
363
364
365
366
367
368
369
370
       
        TransactionLogResource mockQueue = new TransactionLogResource()
        {
            public String getResourceName()
            {
                return mockQueueName.asString();
            }
        };
       
        TransactionLog.Transaction txn = log.newTransaction();
       
View Full Code Here
398
399
400
401
402
403
404
405
406
407
408
       
        TransactionLogResource mockQueue = new TransactionLogResource()
        {
            public String getResourceName()
            {
                return mockQueueName.asString();
            }
        };
       
        TransactionLog.Transaction txn = log.newTransaction();
       
View Full Code Here
439
440
441
442
443
444
445
446
447
448
449
       
        TransactionLogResource mockQueue = new TransactionLogResource()
        {
            public String getResourceName()
            {
                return mockQueueName.asString();
            }
        };
       
        TransactionLog.Transaction txn = log.newTransaction();
       
View Full Code Here
515
516
517
518
519
520
521
522
523
524
525
                QueueEntryKey entryKey = (QueueEntryKey) queueEntryTB.entryToObject(key);
                Long messageId = entryKey.getMessageId();
                AMQShortString queueName = entryKey.getQueueName();
                if (!existingQueues.contains(queueName))
                {
                    String name = queueName.asString();
                    HashSet<Long> messages = phantomMessageQueues.get(name);
                    if (messages == null)
                    {
                        messages = new HashSet<Long>();
                        phantomMessageQueues.put(name, messages);
View Full Code Here
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
                    // if the queue is bound to the exchange but NOT for this topic and selector, then the JMS spec
                    // says we must trash the subscription.
                    boolean isQueueBound = isQueueBound(dest.getExchangeName(), dest.getAMQQueueName());
                    boolean isQueueBoundForTopicAndSelector =
                                isQueueBound(dest.getExchangeName().asString(), dest.getAMQQueueName().asString(), topicName.asString(), args);

                    if (isQueueBound && !isQueueBoundForTopicAndSelector)
                    {
                        deleteQueue(dest.getAMQQueueName());
                    }
View Full Code Here
284
285
286
287
288
289
290
291
292
293
294
        }

        final AMQDestination amqd = (AMQDestination) destination;

        final AMQShortString encodedDestination = amqd.getEncodedName();
        _destinationCache.put(encodedDestination.asString(), destination);
        getContentHeaderProperties().setReplyTo(encodedDestination);
    }

    public Destination getJMSDestination() throws JMSException
    {
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
                try
                {
                    AMQTopic t = new AMQTopic(qpidTopic.getAddress());
                    AMQShortString queueName = getDurableTopicQueueName(subscriptionName, connection);
                    // link is never null if dest was created using an address string.
                    t.getLink().setName(queueName.asString());              
                    t.getLink().getSubscriptionQueue().setAutoDelete(false);
                    t.getLink().setDurable(true);
                   
                    // The legacy fields are also populated just in case.
                    t.setQueueName(queueName);
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
                try
                {
                    AMQTopic t = new AMQTopic(qpidTopic.getAddress());
                    AMQShortString queueName = getDurableTopicQueueName(subscriptionName, connection);
                    // link is never null if dest was created using an address string.
                    t.getLink().setName(queueName.asString());              
                    t.getSourceNode().setAutoDelete(false);
                    t.getSourceNode().setDurable(true);
                   
                    // The legacy fields are also populated just in case.
                    t.setQueueName(queueName);
View Full Code Here
1099
1100
1101
1102
1103
1104
1105
1106
1107
1108
1109
                   
                    // if the queue is bound to the exchange but NOT for this topic and selector, then the JMS spec
                    // says we must trash the subscription.
                    boolean isQueueBound = isQueueBound(dest.getExchangeName(), dest.getAMQQueueName());
                    boolean isQueueBoundForTopicAndSelector =
                                isQueueBound(dest.getExchangeName().asString(), dest.getAMQQueueName().asString(), topicName.asString(), args);

                    if (isQueueBound && !isQueueBoundForTopicAndSelector)
                    {
                        deleteQueue(dest.getAMQQueueName());
                    }
View Full Code Here
453
454
455
456
457
458
459
460
461
462
463
                {
                    AMQBindingURL burl = new AMQBindingURL(origReplyToString);
                    AMQShortString routingKey = burl.getRoutingKey();
                    if(routingKey != null)
                    {
                        replyTo.setRoutingKey(routingKey.asString());
                    }

                    AMQShortString exchangeName = burl.getExchangeName();
                    if(exchangeName != null)
                    {
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.