Examples of MessageMetaData

org.apache.james.mailbox.MessageMetaData
Represent the {@link MessageMetaData} for a message
org.apache.james.mailbox.model.MessageMetaData
Represent the {@link MessageMetaData} for a message
org.apache.james.protocols.pop3.mailbox.MessageMetaData
Hold meta data for a message
org.apache.qpid.server.message.MessageMetaData
Encapsulates a publish body and a content header. In the context of the message store these are treated as a single unit.
org.apache.qpid.server.protocol.v0_8.MessageMetaData
Encapsulates a publish body and a content header. In the context of the message store these are treated as a single unit.
org.apache.qpid.server.queue.MessageMetaData
Encapsulates a publish body and a content header. In the context of the message store these are treated as a single unit.

Examples of org.apache.qpid.server.message.MessageMetaData

        final ArrayList<BaseQueue> qs = new ArrayList<BaseQueue>();


        // Send persistent message


        qs.add(_queue);
        MessageMetaData metaData = msg.headersReceived();
        StoredMessage handle = _store.addMessage(metaData);
        msg.setStoredMessage(handle);




        ServerTransaction txn = new AutoCommitTransaction(_store);

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

            fail(e.getMessage());
        }


        currentMessage.setExpiration();


        MessageMetaData mmd = currentMessage.headersReceived();
        currentMessage.setStoredMessage(getVirtualHost().getMessageStore().addMessage(mmd));
        currentMessage.getStoredMessage().flushToStore();
        currentMessage.route();

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

        {
            final MessagePublishInfo publishBody = readMessagePublishInfo(tupleInput);
            final ContentHeaderBody contentHeaderBody = readContentHeaderBody(tupleInput);
            final int contentChunkCount = tupleInput.readInt();


            return new MessageMetaData(publishBody, contentHeaderBody, contentChunkCount);
        }
        catch (Exception e)
        {
            _log.error("Error converting entry to object: " + e, e);
            // annoyingly just have to return null since we cannot throw

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

        }
    }


    public void objectToEntry(Object object, TupleOutput tupleOutput)
    {
        MessageMetaData message = (MessageMetaData) object;
        try
        {
            writeMessagePublishInfo(message.getMessagePublishInfo(), tupleOutput);
        }
        catch (AMQException e)
        {
            // can't do anything else since the BDB interface precludes throwing any exceptions
            // in practice we should never get an exception
            throw new RuntimeException("Error converting object to entry: " + e, e);
        }
        writeContentHeader(message.getContentHeaderBody(), tupleOutput);
        tupleOutput.writeInt(message.getContentChunkCount());
    }

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

        IncomingMessage msg = message(false, false);
        getQueue().clearQueue();
        ArrayList<AMQQueue> qs = new ArrayList<AMQQueue>();
        qs.add(getQueue());
        msg.enqueue(qs);
        MessageMetaData mmd = msg.headersReceived();
        msg.setStoredMessage(getMessageStore().addMessage(mmd));
        long id = msg.getMessageNumber();


        msg.addContentBodyFrame(new ContentChunk()
        {

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

            ArrayList<AMQQueue> qs = new ArrayList<AMQQueue>();
            qs.add(getQueue());
            currentMessage.enqueue(qs);


            // route header
            MessageMetaData mmd = currentMessage.headersReceived();
            currentMessage.setStoredMessage(getMessageStore().addMessage(mmd));


            // Add the body so we have somthing to test later
            currentMessage.addContentBodyFrame(
                    getSession().getMethodRegistry()

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

        DatabaseVisitor metaDataVisitor = new DatabaseVisitor()
        {
            public void visit(DatabaseEntry key, DatabaseEntry value) throws DatabaseException
            {
                _count++;
                MessageMetaData metaData = (MessageMetaData) oldMetaDataTupleBinding.entryToObject(value);


                // get message id
                Long messageId = TupleBinding.getPrimitiveBinding(Long.class).entryToObject(key);


                // ONLY copy data if message is delivered to existing queue

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

            TupleBinding<Long> longTB = TupleBinding.getPrimitiveBinding(Long.class);
            TupleBinding<Object> metaDataTB = new MessageMetaDataTupleBindingFactory(storeVersion).getInstance();
            key = new DatabaseEntry();
            data = new DatabaseEntry();
            longTB.objectToEntry(new Long(messageId), key);
            MessageMetaData metaData = new MessageMetaData(pubInfoBody, contentHeaderBody, 1);
            metaDataTB.objectToEntry(metaData, data);
            store.getMetaDataDb().put(null, key, data);


            // add delivery entry to database
            TransactionLogResource mockQueue = new TransactionLogResource()

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

        MessagePublishInfo pubInfoBody_0_8 = createPublishInfoBody_0_8();
        BasicContentHeaderProperties props_0_8 = createContentHeaderProperties_0_8();


        ContentHeaderBody chb_0_8 = createContentHeaderBody_0_8(props_0_8, bodySize);


        MessageMetaData messageMetaData_0_8 = new MessageMetaData(pubInfoBody_0_8, chb_0_8, 0);
        StoredMessage<MessageMetaData> storedMessage_0_8 = bdbStore.addMessage(messageMetaData_0_8);


        long origArrivalTime_0_8 = messageMetaData_0_8.getArrivalTime();
        long messageid_0_8 = storedMessage_0_8.getMessageNumber();


        storedMessage_0_8.addContent(0, firstContentBytes_0_8);
        storedMessage_0_8.addContent(firstContentBytes_0_8.limit(), secondContentBytes_0_8);
        storedMessage_0_8.flushToStore();


        /*
         * Create and insert a 0-10 message (metadata and content)
         */        
        MessageProperties msgProps_0_10 = createMessageProperties_0_10(bodySize);
        DeliveryProperties delProps_0_10 = createDeliveryProperties_0_10();
        Header header_0_10 = new Header(msgProps_0_10, delProps_0_10);


        MessageTransfer xfr_0_10 = new MessageTransfer("destination", MessageAcceptMode.EXPLICIT, 
                MessageAcquireMode.PRE_ACQUIRED, header_0_10, completeContentBody_0_10);


        MessageMetaData_0_10 messageMetaData_0_10 = new MessageMetaData_0_10(xfr_0_10);
        StoredMessage<MessageMetaData_0_10> storedMessage_0_10 = bdbStore.addMessage(messageMetaData_0_10);


        long origArrivalTime_0_10 = messageMetaData_0_10.getArrivalTime();
        long messageid_0_10 = storedMessage_0_10.getMessageNumber();


        storedMessage_0_10.addContent(0, completeContentBody_0_10);
        storedMessage_0_10.flushToStore();


        /*
         * reload the store only (read-only)
         */
        bdbStore = reloadStoreReadOnly(bdbStore);


        /*
         * Read back and validate the 0-8 message metadata and content
         */
        StorableMessageMetaData storeableMMD_0_8 = bdbStore.getMessageMetaData(messageid_0_8);


        assertEquals("Unexpected message type",MessageMetaDataType.META_DATA_0_8, storeableMMD_0_8.getType());
        assertTrue("Unexpected instance type", storeableMMD_0_8 instanceof MessageMetaData);
        MessageMetaData returnedMMD_0_8 = (MessageMetaData) storeableMMD_0_8;


        assertEquals("Message arrival time has changed", origArrivalTime_0_8, returnedMMD_0_8.getArrivalTime());


        MessagePublishInfo returnedPubBody_0_8 = returnedMMD_0_8.getMessagePublishInfo();
        assertEquals("Message exchange has changed", pubInfoBody_0_8.getExchange(), returnedPubBody_0_8.getExchange());
        assertEquals("Immediate flag has changed", pubInfoBody_0_8.isImmediate(), returnedPubBody_0_8.isImmediate());
        assertEquals("Mandatory flag has changed", pubInfoBody_0_8.isMandatory(), returnedPubBody_0_8.isMandatory());
        assertEquals("Routing key has changed", pubInfoBody_0_8.getRoutingKey(), returnedPubBody_0_8.getRoutingKey());


        ContentHeaderBody returnedHeaderBody_0_8 = returnedMMD_0_8.getContentHeaderBody();
        assertEquals("ContentHeader ClassID has changed", chb_0_8.classId, returnedHeaderBody_0_8.classId);
        assertEquals("ContentHeader weight has changed", chb_0_8.weight, returnedHeaderBody_0_8.weight);
        assertEquals("ContentHeader bodySize has changed", chb_0_8.bodySize, returnedHeaderBody_0_8.bodySize);


        BasicContentHeaderProperties returnedProperties_0_8 = (BasicContentHeaderProperties) returnedHeaderBody_0_8.getProperties();

View Full Code Here

Examples of org.apache.qpid.server.message.MessageMetaData

        MessagePublishInfo pubInfoBody_0_8 = createPublishInfoBody_0_8();
        BasicContentHeaderProperties props_0_8 = createContentHeaderProperties_0_8();


        ContentHeaderBody chb_0_8 = createContentHeaderBody_0_8(props_0_8, bodySize);


        MessageMetaData messageMetaData_0_8 = new MessageMetaData(pubInfoBody_0_8, chb_0_8, 0);
        StoredMessage<MessageMetaData> storedMessage_0_8 = store.addMessage(messageMetaData_0_8);


        storedMessage_0_8.addContent(0, chunk1);
        storedMessage_0_8.addContent(chunk1.limit(), chunk2);
        storedMessage_0_8.flushToStore();

View Full Code Here

0 1 2 3 4 5

TOP

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.