Package org.apache.qpid.server.model

Examples of org.apache.qpid.server.model.Exchange

252
253
254
255
256
257
258
259
260
261
262
263
    }

    public void testGetAlternateExchange()
    {
        Exchange mockAlternateExchange = mock(Exchange.class);
        when(mockAlternateExchange.getName()).thenReturn(QUEUE_ALTERNATE_EXCHANGE);

        when(_mockQueue.getAttribute(Queue.ALTERNATE_EXCHANGE)).thenReturn(mockAlternateExchange);

        assertEquals(QUEUE_ALTERNATE_EXCHANGE, _queueMBean.getAlternateExchange());
    }
View Full Code Here
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
        assertNull(_queueMBean.getAlternateExchange());
    }

    public void testSetAlternateExchange() throws Exception
    {
        Exchange mockExchange1 = mock(Exchange.class);
        when(mockExchange1.getName()).thenReturn("exchange1");

        Exchange mockExchange2 = mock(Exchange.class);
        when(mockExchange2.getName()).thenReturn("exchange2");

        Exchange mockExchange3 = mock(Exchange.class);
        when(mockExchange3.getName()).thenReturn("exchange3");

        VirtualHost mockVirtualHost = mock(VirtualHost.class);
        when(mockVirtualHost.getExchanges()).thenReturn(Arrays.asList(new Exchange[] {mockExchange1, mockExchange2, mockExchange3}));
        when(_mockQueue.getParent(VirtualHost.class)).thenReturn(mockVirtualHost);
View Full Code Here
288
289
290
291
292
293
294
295
296
297
298
299
        verify(_mockQueue).setAttribute(Queue.ALTERNATE_EXCHANGE, null, mockExchange2);
    }

    public void testSetAlternateExchangeWithUnknownExchangeName() throws Exception
    {
        Exchange mockExchange = mock(Exchange.class);
        when(mockExchange.getName()).thenReturn("exchange1");

        VirtualHost mockVirtualHost = mock(VirtualHost.class);
        when(mockVirtualHost.getExchanges()).thenReturn(Collections.singletonList(mockExchange));
        when(_mockQueue.getParent(VirtualHost.class)).thenReturn(mockVirtualHost);
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
175
        verify(_mockVirtualHost, never()).createExchange(TEST_EXCHANGE_NAME, State.ACTIVE, true, LifetimePolicy.PERMANENT, exchangeType, EMPTY_ARGUMENT_MAP);
    }

    public void testUnregisterExchange() throws Exception
    {
        Exchange mockExchange = mock(Exchange.class);
        when(mockExchange.getName()).thenReturn("exchange1");
        when(_mockVirtualHost.getExchanges()).thenReturn(Collections.singletonList(mockExchange));

        _virtualHostManagerMBean.unregisterExchange("exchange1");
        verify(mockExchange).delete();
    }
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
185
        verify(mockExchange).delete();
    }

    public void testUnregisterExchangeWhenExchangeDoesNotExist() throws Exception
    {
        Exchange mockExchange = mock(Exchange.class);
        when(mockExchange.getName()).thenReturn("exchange1");
        when(_mockVirtualHost.getExchanges()).thenReturn(Collections.singletonList(mockExchange));

        try
        {
            _virtualHostManagerMBean.unregisterExchange("unknownexchange");
View Full Code Here
563
564
565
566
567
568
569
570
571
572
573
574
    {
        if(childClass == org.apache.qpid.server.model.Binding.class)
        {
            if(otherParents != null && otherParents.length == 1 && otherParents[0] instanceof Exchange)
            {
                Exchange exchange = (Exchange) otherParents[0];
                if(exchange.getParent(org.apache.qpid.server.model.VirtualHost.class) == getParent(org.apache.qpid.server.model.VirtualHost.class))
                {
                    return (C) createBinding(exchange, attributes);
                }
                else
                {
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
        }
    }

    public static  Exchange findExchangeFromExchangeName(VirtualHost virtualHost, String exchangeName) throws OperationsException
    {
        Exchange exchange = ConfiguredObjectFinder.findConfiguredObjectByName(virtualHost.getExchanges(), exchangeName);
        if (exchange == null)
        {
            throw new OperationsException("No such exchange \""+exchangeName+"\"");
        }
        else
View Full Code Here
278
279
280
281
282
283
284
285
286
287
            _queue.setAttribute(Queue.ALTERNATE_EXCHANGE, getAlternateExchange(), null);
        }
        else
        {
            VirtualHost virtualHost = _queue.getParent(VirtualHost.class);
            Exchange exchange = MBeanUtils.findExchangeFromExchangeName(virtualHost, exchangeName);

            _queue.setAttribute(Queue.ALTERNATE_EXCHANGE, getAlternateExchange(), exchange);
        }
    }
View Full Code Here
286
287
288
289
290
291
292
293
        }
    }

    public String getAlternateExchange()
    {
        Exchange alternateExchange = (Exchange) _queue.getAttribute(Queue.ALTERNATE_EXCHANGE);
        return alternateExchange == null ? null : alternateExchange.getName();
    }
View Full Code Here
241
242
243
244
245
246
247
248
249
250
251
252
    /**********  Other attributes **********/

    public void testGetAlternateExchange()
    {
        Exchange mockAlternateExchange = mock(Exchange.class);
        when(mockAlternateExchange.getName()).thenReturn(QUEUE_ALTERNATE_EXCHANGE);

        when(_mockQueue.getAttribute(Queue.ALTERNATE_EXCHANGE)).thenReturn(mockAlternateExchange);

        assertEquals(QUEUE_ALTERNATE_EXCHANGE, _queueMBean.getAlternateExchange());
    }
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.model.Exchange

  • org.apache.qpid.server.exchange.AbstractExchange
  • org.apache.qpid.server.jmx.mbeans.MBeanUtils
  • org.apache.qpid.server.jmx.mbeans.QueueMBean
  • org.apache.qpid.server.jmx.mbeans.QueueMBeanTest
  • org.apache.qpid.server.jmx.mbeans.VirtualHostManagerMBean
  • org.apache.qpid.server.jmx.mbeans.VirtualHostManagerMBeanTest
  • org.apache.qpid.server.model.adapter.QueueAdapter
  • org.apache.qpid.server.protocol.v0_10.ConsumerTarget_0_10
  • org.apache.qpid.server.protocol.v0_8.AMQChannel
  • org.apache.qpid.server.qmf2.agentdata.Broker
    • 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.