List of decrementReference() Examples

Examples of decrementReference()

org.apache.qpid.server.message.AMQMessage.decrementReference()
Threadsafe. This will decrement the reference count and when it reaches zero will remove the message from the message store. @throws org.apache.qpid.server.queue.MessageCleanupException when an attempt was made to remove the message from the message store and thatfailed
org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference()
Threadsafe. This will decrement the reference count and when it reaches zero will remove the message from the message store. @throws org.apache.qpid.server.queue.MessageCleanupException when an attempt was made to remove the message from the message store and thatfailed
org.apache.qpid.server.queue.AMQMessage.decrementReference()
Threadsafe. This will decrement the reference count and when it reaches zero will remove the message from the message store. @param storeContext @throws MessageCleanupException when an attempt was made to remove the message from the message store and thatfailed

Examples of org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference()

                        {
                            try
                            {


                                queue.enqueue(message, true, null);
                                message.decrementReference();
                            }
                            catch (AMQException e)
                            {
                                _logger.error("Unable to enqueue message " + message.getMessageNumber() + " into " +
                                              "queue " + queue.getName() + " (from XA transaction)", e);

View Full Code Here

Examples of org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference()

                            }
                        }


                        public void onRollback()
                        {
                            message.decrementReference();
                        }
                    });
                }
                else
                {

View Full Code Here

Examples of org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference()

                        {
                            try
                            {


                                queue.enqueue(message, true, null);
                                message.decrementReference();
                            }
                            catch (AMQException e)
                            {
                                _logger.error("Unable to enqueue message " + message.getMessageNumber() + " into " +
                                              "queue " + queue.getName() + " (from XA transaction)", e);

View Full Code Here

Examples of org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference()

                            }
                        }


                        public void onRollback()
                        {
                            message.decrementReference();
                        }
                    });
                }
                else
                {

View Full Code Here

Examples of org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference()

                        {
                            try
                            {


                                queue.enqueue(message, true, null);
                                message.decrementReference();
                            }
                            catch (AMQException e)
                            {
                                _logger.error("Unable to enqueue message " + message.getMessageNumber() + " into " +
                                              "queue " + queue.getName() + " (from XA transaction)", e);

View Full Code Here

Examples of org.apache.qpid.server.message.AbstractServerMessageImpl.decrementReference()

                            }
                        }


                        public void onRollback()
                        {
                            message.decrementReference();
                        }
                    });
                }
                else
                {

View Full Code Here

Examples of org.apache.qpid.server.queue.AMQMessage.decrementReference()

            {
                AMQMessage message = bouncedMessage.getAMQMessage();
                _session.getProtocolOutputConverter().writeReturn(message, _channelId, bouncedMessage.getReplyCode().getCode(),
                                                                 new AMQShortString(bouncedMessage.getMessage()));


                message.decrementReference(_storeContext);
            }


            _returnMessages.clear();
        }
    }

View Full Code Here

Examples of org.apache.qpid.server.queue.AMQMessage.decrementReference()

            {
                AMQMessage message = bouncedMessage.getAMQMessage();
                _session.getProtocolOutputConverter().writeReturn(message, _channelId, bouncedMessage.getReplyCode().getCode(),
                                                                 new AMQShortString(bouncedMessage.getMessage()));


                message.decrementReference(_storeContext);
            }


            _returnMessages.clear();
        }
    }

View Full Code Here

Examples of org.apache.qpid.server.queue.AMQMessage.decrementReference()

        message = message.takeReference();


        // we call routing complete to set up the handle
        message.routingComplete(_store, _storeContext, new MessageHandleFactory());
        assertTrue(_store.getMessageMetaDataMap().size() == 1);
        message.decrementReference(_storeContext);
        assertTrue(_store.getMessageMetaDataMap().size() == 0);
    }


    private ContentHeaderBody createPersistentContentHeader()
    {

View Full Code Here

Examples of org.apache.qpid.server.queue.AMQMessage.decrementReference()

        message = message.takeReference();
        // we call routing complete to set up the handle
        message.routingComplete(_store, _storeContext, new MessageHandleFactory());
        assertTrue(_store.getMessageMetaDataMap().size() == 1);
        message = message.takeReference();
        message.decrementReference(_storeContext);
        assertTrue(_store.getMessageMetaDataMap().size() == 1);
    }


    public static junit.framework.Test suite()
    {

View Full Code Here

0 1 2

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.