Package org.apache.qpid.amqp_1_0.type

Examples of org.apache.qpid.amqp_1_0.type.Binary

267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
                    header.setTtl(oldHeader.getTtl());
                }
                header.setDeliveryCount(UnsignedInteger.valueOf(queueEntry.getDeliveryCount()));
                _sectionEncoder.reset();
                _sectionEncoder.encodeObject(header);
                Binary encodedHeader = _sectionEncoder.getEncoding();

                ByteBuffer oldPayload = payload;
                payload = ByteBuffer.allocate(oldPayload.remaining() + encodedHeader.getLength());
                payload.put(encodedHeader.getArray(),encodedHeader.getArrayOffset(),encodedHeader.getLength());
                payload.put(oldPayload);
                payload.flip();
            }

            transfer.setPayload(payload);
            byte[] data = new byte[8];
            ByteBuffer.wrap(data).putLong(_deliveryTag++);
            final Binary tag = new Binary(data);

            transfer.setDeliveryTag(tag);

            synchronized(_link.getLock())
            {
View Full Code Here
486
487
488
489
490
491
492
493
494
495
496
        }

        public boolean process(DeliveryState state, final Boolean settled)
        {

            Binary transactionId = null;
            final Outcome outcome;
            // If disposition is settled this overrides the txn?
            if(state instanceof TransactionalState)
            {
                transactionId = ((TransactionalState)state).getTxnId();
View Full Code Here
605
606
607
608
609
610
611
612
613
614
615
        {
        }

        public boolean process(final DeliveryState state, final Boolean settled)
        {
            Binary transactionId = null;
            Outcome outcome = null;
            // If disposition is settled this overrides the txn?
            if(state instanceof TransactionalState)
            {
                transactionId = ((TransactionalState)state).getTxnId();
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121

            Sender s = session.createSender(queue, 10);

            Message message = new Message("dump me");
            message.setDeliveryTag(new Binary("dump".getBytes()));

            s.send(message);

            s.close();
            session.close();
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
            msg.setTtl(null);
        }

        if(!getDisableMessageID() && msg.getMessageId() == null)
        {
            final Binary messageId = generateMessageId();
            msg.setMessageId(messageId);

        }

        if(message != msg)
View Full Code Here
260
261
262
263
264
265
266
    }

    private Binary generateMessageId()
    {
        UUID uuid = UUID.randomUUID();
        return new Binary(uuid.toString().getBytes());
    }
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
                            System.arraycopy(origBytes,0,bytes,0,origBytes.length);
                            for(int x = origBytes.length; x < bytes.length; x++)
                            {
                                bytes[x] = (byte) '.';
                            }
                            bodySection = new Data(new Binary(bytes));
                        }
                        else
                        {
                            bodySection = new AmqpValue(message + " " + i);
                        }
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
                for(String fileName : unsettledFiles)
                {
                    File aFile = new File(tmpDirectory, fileName);
                    if(aFile.canRead() && aFile.canWrite())
                    {
                        Binary deliveryTag = new Binary(md5.digest(fileName.getBytes()));
                        unsettled.put(deliveryTag, null);
                        unsettledFileNames.put(deliveryTag, fileName);
                    }
                }
View Full Code Here
279
280
281
282
283
284
285
286
287
288
289
290
        int read = fis.read(data);

        fis.close();

        Section applicationProperties = new ApplicationProperties(Collections.singletonMap("filename", fileName));
        Section amqpValue = new Data(new Binary(data));
        Message message = new Message(Arrays.asList(applicationProperties, amqpValue));
        Binary deliveryTag = new Binary(md5.digest(fileName.getBytes()));
        message.setDeliveryTag(deliveryTag);
        md5.reset();
        return message;
    }
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
133
134
    {

        Object o = getCorrelationId();
        if(o instanceof Binary)
        {
            Binary correlationIdBinary = (Binary) o;
            byte[] correlationId = new byte[correlationIdBinary.getLength()];
            correlationIdBinary.asByteBuffer().get(correlationId);
            return correlationId;
        }
        else
        {
            return o == null ? null : o.toString().getBytes();
View Full Code Here
TOP

Related Classes of org.apache.qpid.amqp_1_0.type.Binary

  • org.apache.activemq.karaf.itest.ActiveMQAMQPBrokerFeatureTest
  • org.apache.activemq.transport.amqp.AMQ4563Test
  • org.apache.activemq.transport.amqp.AMQ4696Test
  • org.apache.activemq.transport.amqp.AMQ4920Test
  • org.apache.activemq.transport.amqp.AMQ4930ConsumerTask
  • org.apache.activemq.transport.amqp.AmqpTransformerTest
  • org.apache.activemq.transport.amqp.bugs.AMQ4753Test
  • org.apache.activemq.transport.amqp.bugs.AMQ4914Test
  • org.apache.activemq.transport.amqp.JmsClientRequestResponseTest
  • org.apache.activemq.transport.amqp.JMSClientTest
    • Copyright © 2018 www.massapicom. 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.