Package org.apache.qpid.server.store

Examples of org.apache.qpid.server.store.TransactionLogResource

508
509
510
511
512
513
514
515
516
517
518
        MessageStore log = getVirtualHost().getMessageStore();

        AbstractBDBMessageStore bdbStore = assertBDBStore(log);

        final UUID mockQueueId = UUIDGenerator.generateRandomUUID();
        TransactionLogResource mockQueue = new TransactionLogResource()
        {
            @Override
            public UUID getId()
            {
                return mockQueueId;
View Full Code Here
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
    private class CheckCapacityAction implements Action<MessageInstance>
    {
        @Override
        public void performAction(final MessageInstance entry)
        {
            TransactionLogResource queue = entry.getOwningResource();
            if(queue instanceof CapacityChecker)
            {
                ((CapacityChecker)queue).checkCapacity(ServerSession.this);
            }
        }
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
        try
        {
            for(MessageInstance entry : queueEntries)
            {
                ServerMessage message = entry.getMessage();
                TransactionLogResource queue = entry.getOwningResource();

                if(message.isPersistent() && queue.isDurable())
                {
                    if (_logger.isDebugEnabled())
                    {
                        _logger.debug("Dequeue of message number " + message.getMessageNumber() + " from transaction log. Queue : " + queue.getName());
                    }

                    if(txn == null)
                    {
                        txn = _messageStore.newTransaction();
View Full Code Here
411
412
413
414
415
416
417
418
419
420
421
        MessageStore log = getVirtualHost().getMessageStore();

        AbstractBDBMessageStore bdbStore = assertBDBStore(log);

        final UUID mockQueueId = UUIDGenerator.generateRandomUUID();
        TransactionLogResource mockQueue = new TransactionLogResource()
        {
            @Override
            public String getName()
            {
                return getId().toString();
View Full Code Here
461
462
463
464
465
466
467
468
469
470
471
        MessageStore log = getVirtualHost().getMessageStore();

        AbstractBDBMessageStore bdbStore = assertBDBStore(log);

        final UUID mockQueueId = UUIDGenerator.generateRandomUUID();
        TransactionLogResource mockQueue = new TransactionLogResource()
        {
            @Override
            public String getName()
            {
                return getId().toString();
View Full Code Here
530
531
532
533
534
535
536
537
538
539
540
        MessageStore log = getVirtualHost().getMessageStore();

        AbstractBDBMessageStore bdbStore = assertBDBStore(log);

        final UUID mockQueueId = UUIDGenerator.generateRandomUUID();
        TransactionLogResource mockQueue = new TransactionLogResource()
        {
            @Override
            public String getName()
            {
                return getId().toString();
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
        try
        {
            for(MessageInstance entry : queueEntries)
            {
                ServerMessage message = entry.getMessage();
                TransactionLogResource queue = entry.getOwningResource();

                if(message.isPersistent() && queue.isDurable())
                {
                    if (_logger.isDebugEnabled())
                    {
                        _logger.debug("Dequeue of message number " + message.getMessageNumber() + " from transaction log. Queue : " + queue.getName());
                    }

                    if(txn == null)
                    {
                        txn = _messageStore.newTransaction();
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
        try
        {
            for(MessageInstance entry : queueEntries)
            {
                ServerMessage message = entry.getMessage();
                TransactionLogResource queue = entry.getOwningResource();

                if(message.isPersistent() && queue.isDurable())
                {
                    if (_logger.isDebugEnabled())
                    {
                        _logger.debug("Dequeue of message number " + message.getMessageNumber() + " from transaction log. Queue : " + queue.getName());
                    }

                    beginTranIfNecessary();
                    _transaction.dequeueMessage(queue, message);
                }
View Full Code Here
399
400
401
402
403
404
405
406
407
408
409
                        }
                    }, null);

        if (requeues == 0)
        {
            TransactionLogResource owningResource = entry.getOwningResource();
            if(owningResource instanceof AMQQueue)
            {
                final AMQQueue queue = (AMQQueue)owningResource;
                final ExchangeImpl alternateExchange = queue.getAlternateExchange();
View Full Code Here
276
277
278
279
280
281
282
283
284
285
286
287
        }
        else
        {
            _logger.warn("Message id " + messageId + " in log references queue with id " + queueId + " which is not in the configuration, entry will be discarded");
            Transaction txn = _store.newTransaction();
            TransactionLogResource mockQueue =
                    new TransactionLogResource()
                    {
                        @Override
                        public String getName()
                        {
                            return "<<UNKNOWN>>";
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.store.TransactionLogResource

  • org.apache.qpid.server.message.AbstractServerMessageTest
  • org.apache.qpid.server.protocol.v0_10.ConsumerTarget_0_10
  • org.apache.qpid.server.protocol.v0_10.ServerSession$CheckCapacityAction
  • org.apache.qpid.server.protocol.v0_8.AMQChannel
  • org.apache.qpid.server.protocol.v0_8.AMQChannel$CapacityCheckAction
  • org.apache.qpid.server.protocol.v0_8.AMQChannel$ImmediateAction
  • org.apache.qpid.server.protocol.v0_8.ReferenceCountingTest
  • org.apache.qpid.server.store.berkeleydb.BDBMessageStoreTest
  • org.apache.qpid.server.store.berkeleydb.BDBUpgradeTest
  • org.apache.qpid.server.txn.AsyncAutoCommitTransaction
    • 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.