1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
package org.apache.qpid.extras.exchanges.example;
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
import java.util.List;
import java.util.Map;
import java.util.ArrayList;
import org.apache.qpid.AMQException;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.framing.FieldTable;
import org.apache.qpid.server.exchange.Exchange;
import org.apache.qpid.server.queue.AMQQueue;
import org.apache.qpid.server.virtualhost.VirtualHost;
import org.apache.qpid.server.message.InboundMessage;
public class TestExchange implements Exchange
{
public void close() throws AMQException
{
}
public void deregisterQueue(AMQShortString routingKey, AMQQueue queue, FieldTable args) throws AMQException
{
}
public Map<AMQShortString, List<AMQQueue>> getBindings()
{
return null;
}
public AMQShortString getName()
{
return null;
}
public AMQShortString getType()
{
return null;
}
public boolean hasBindings()
{
return false;
}
public boolean isBound(String bindingKey, AMQQueue queue)
{
return false;
}
public boolean isBound(String bindingKey)
{
return false;
}
public Exchange getAlternateExchange()
{
return null; //To change body of implemented methods use File | Settings | File Templates.
}
public void setAlternateExchange(Exchange exchange)
{
//To change body of implemented methods use File | Settings | File Templates.
}
public void initialise(VirtualHost host, AMQShortString name, boolean durable, boolean autoDelete)
throws AMQException
{
}
public boolean isAutoDelete()
{
return false;
}
public boolean isBound(AMQShortString routingKey, FieldTable arguments, AMQQueue queue)
{
return false;
}
public boolean isBound(AMQShortString routingKey, AMQQueue queue)
{
return false;
}
public boolean isBound(AMQShortString routingKey)
{
return false;
}
public boolean isBound(AMQQueue queue)
{
return false;
}
public boolean isDurable()
{
return false;
}
public void registerQueue(AMQShortString routingKey, AMQQueue queue, FieldTable args) throws AMQException
{
}
public ArrayList<AMQQueue> route(InboundMessage message)
{
return new ArrayList<AMQQueue>();
}
public int getTicket()
{
return 0;
}
public void initialise(VirtualHost arg0, AMQShortString arg1, boolean arg2, int arg3, boolean arg4)
throws AMQException
{
}
}
|
