Examples of DtxRegistry

Examples of org.apache.qpid.server.txn.DtxRegistry

146
147
148
149
150
151
152
153
154
155
156
        _virtualHostRegistry = virtualHostRegistry;
        _brokerStatisticsGatherer = brokerStatisticsGatherer;
        _vhostConfig = hostConfig;
        _name = _vhostConfig.getName();
        _dtxRegistry = new DtxRegistry();
        _model = virtualHost;
        _eventLogger = virtualHostRegistry.getEventLogger();

        _id = UUIDGenerator.generateVhostUUID(_name);
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
    public void dtxRecord(long format, byte[] globalId, byte[] branchId,
                          Transaction.Record[] enqueues,
                          Transaction.Record[] dequeues)
    {
        Xid id = new Xid(format, globalId, branchId);
        DtxRegistry dtxRegistry = _virtualHost.getDtxRegistry();
        DtxBranch branch = dtxRegistry.getBranch(id);
        if(branch == null)
        {
            branch = new DtxBranch(id, _store, _virtualHost);
            dtxRegistry.registerBranch(branch);
        }
        for(Transaction.Record record : enqueues)
        {
            final AMQQueue queue = _virtualHost.getQueue(record.getResource().getId());
            if(queue != null)
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
                                  byte[] branchId,
                                  Transaction.Record[] enqueues,
                                  Transaction.Record[] dequeues)
            {
                Xid id = new Xid(format, globalId, branchId);
                DtxRegistry dtxRegistry = getVirtualHost().getDtxRegistry();
                DtxBranch branch = dtxRegistry.getBranch(id);
                if (branch == null)
                {
                    branch = new DtxBranch(id, getStore(), getVirtualHost());
                    dtxRegistry.registerBranch(branch);
                }
                for (Transaction.Record record : enqueues)
                {
                    final AMQQueue<?> queue = getVirtualHost().getQueue(record.getResource().getId());
                    if (queue != null)
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
        @Override
        public boolean handle(long format, byte[] globalId, byte[] branchId, Record[] enqueues, Record[] dequeues)
        {
            Xid id = new Xid(format, globalId, branchId);
            DtxRegistry dtxRegistry = _virtualHost.getDtxRegistry();
            DtxBranch branch = dtxRegistry.getBranch(id);
            if(branch == null)
            {
                branch = new DtxBranch(id, _store, _virtualHost);
                dtxRegistry.registerBranch(branch);
            }
            for(Transaction.Record record : enqueues)
            {
                final AMQQueue<?> queue = _virtualHost.getQueue(record.getResource().getId());
                if(queue != null)
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
            {
                return transaction;
            }
        };

        DtxRegistry dtxRegistry = new DtxRegistry();

        when(_virtualHost.getMessageStore()).thenReturn(store);
        when(_virtualHost.getDtxRegistry()).thenReturn(dtxRegistry);

        SynchronousMessageStoreRecoverer
                recoverer = new SynchronousMessageStoreRecoverer();
        recoverer.recover(_virtualHost);

        DtxBranch branch = dtxRegistry.getBranch(new Xid(format, globalId, branchId));
        assertNotNull("Expected dtx branch to be created", branch);
        branch.commit();

        ServerMessage<?> message = storedMessage.getMetaData().getType().createMessage(storedMessage);
        verify(queue, times(1)).enqueue(eq(message), (Action<? super MessageInstance>)isNull());
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
            {
                return transaction;
            }
        };

        DtxRegistry dtxRegistry = new DtxRegistry();

        when(_virtualHost.getMessageStore()).thenReturn(store);
        when(_virtualHost.getDtxRegistry()).thenReturn(dtxRegistry);

        SynchronousMessageStoreRecoverer
                recoverer = new SynchronousMessageStoreRecoverer();
        recoverer.recover(_virtualHost);

        DtxBranch branch = dtxRegistry.getBranch(new Xid(format, globalId, branchId));
        assertNotNull("Expected dtx branch to be created", branch);
        branch.commit();

        verify(queueEntry, times(1)).delete();
        verify(transaction).commitTran();
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

170
171
172
173
174
175
176
177
178
179
180
    {
        super(parentsMap(virtualHostNode), attributes);
        _broker = virtualHostNode.getParent(Broker.class);
        _virtualHostNode = virtualHostNode;

        _dtxRegistry = new DtxRegistry();

        _eventLogger = _broker.getParent(SystemConfig.class).getEventLogger();

        _eventLogger.message(VirtualHostMessages.CREATED(getName()));
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

188
189
190
191
192
193
194
195
196
197
198
   
        _appRegistry = appRegistry;
        _broker = _appRegistry.getBroker();
        _configuration = hostConfig;
        _name = _configuration.getName();
        _dtxRegistry = new DtxRegistry();

        _id = _appRegistry.getConfigStore().createId();

        CurrentActor.get().message(VirtualHostMessages.CREATED(_name));
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
    public void dtxRecord(long format, byte[] globalId, byte[] branchId,
                          MessageStore.Transaction.Record[] enqueues,
                          MessageStore.Transaction.Record[] dequeues)
    {
        Xid id = new Xid(format, globalId, branchId);
        DtxRegistry dtxRegistry = _virtualHost.getDtxRegistry();
        DtxBranch branch = dtxRegistry.getBranch(id);
        if(branch == null)
        {
            branch = new DtxBranch(id, _store, _virtualHost);
            dtxRegistry.registerBranch(branch);
        }
        for(MessageStore.Transaction.Record record : enqueues)
        {
            final AMQQueue queue = _virtualHost.getQueueRegistry().getQueue(record.getQueue().getResourceName());
            if(queue != null)
View Full Code Here

Examples of org.apache.qpid.server.txn.DtxRegistry

176
177
178
179
180
181
182
183
184
185
186
    {
        super(parentsMap(virtualHostNode), attributes);
        _broker = virtualHostNode.getParent(Broker.class);
        _virtualHostNode = virtualHostNode;

        _dtxRegistry = new DtxRegistry();

        _eventLogger = _broker.getParent(SystemConfig.class).getEventLogger();

        _eventLogger.message(VirtualHostMessages.CREATED(getName()));
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.