blob: c4fbeb56072c72bc8847353c49598204bce2e9cc (
plain)
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
|
/*
*
* 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.
*
*/
package org.apache.qpid.jms;
import java.util.List;
import org.apache.qpid.framing.AMQShortString;
/**
Connection URL format
amqp://[user:pass@][clientid]/virtualhost?brokerlist='tcp://host:port?option=\'value\'&option=\'value\';tcp://host:port/virtualpath?option=\'value\''&failover='method?option=\'value\'&option='value''"
Options are of course optional except for requiring a single broker in the broker list.
The option seperator is defined to be either '&' or ','
*/
public interface ConnectionURL
{
public static final String AMQ_PROTOCOL = "amqp";
public static final String OPTIONS_SYNC_PERSISTENCE = "sync_persistence";
public static final String OPTIONS_MAXPREFETCH = "maxprefetch";
public static final String OPTIONS_SYNC_ACK = "sync_ack";
public static final String OPTIONS_SYNC_PUBLISH = "sync_publish";
public static final String OPTIONS_USE_LEGACY_MAP_MESSAGE_FORMAT = "use_legacy_map_msg_format";
public static final String OPTIONS_USE_LEGACY_STREAM_MESSAGE_FORMAT = "use_legacy_stream_msg_format";
public static final String OPTIONS_BROKERLIST = "brokerlist";
public static final String OPTIONS_FAILOVER = "failover";
public static final String OPTIONS_FAILOVER_CYCLE = "cyclecount";
/**
* This option is used to apply a connection level override of
* the {@value BrokerDetails#OPTIONS_SSL} option values in the
* {@value ConnectionURL#OPTIONS_BROKERLIST};
*/
public static final String OPTIONS_SSL = "ssl";
/**
* This option is only applicable for 0-8/0-9/0-9-1 protocols connection
* <p>
* It tells the client to delegate the requeue/DLQ decision to the
* server .If this option is not specified, the messages won't be moved to
* the DLQ (or dropped) when delivery count exceeds the maximum.
*/
public static final String OPTIONS_REJECT_BEHAVIOUR = "rejectbehaviour";
public static final String OPTIONS_DEFAULT_TOPIC_EXCHANGE = "defaultTopicExchange";
public static final String OPTIONS_DEFAULT_QUEUE_EXCHANGE = "defaultQueueExchange";
public static final String OPTIONS_TEMPORARY_TOPIC_EXCHANGE = "temporaryTopicExchange";
public static final String OPTIONS_TEMPORARY_QUEUE_EXCHANGE = "temporaryQueueExchange";
public static final String OPTIONS_VERIFY_QUEUE_ON_SEND = "verifyQueueOnSend";
public static final byte URL_0_8 = 1;
public static final byte URL_0_10 = 2;
String getURL();
String getFailoverMethod();
String getFailoverOption(String key);
int getBrokerCount();
BrokerDetails getBrokerDetails(int index);
void addBrokerDetails(BrokerDetails broker);
void setBrokerDetails(List<BrokerDetails> brokers);
List<BrokerDetails> getAllBrokerDetails();
String getClientName();
void setClientName(String clientName);
String getUsername();
void setUsername(String username);
String getPassword();
void setPassword(String password);
String getVirtualHost();
void setVirtualHost(String virtualHost);
String getOption(String key);
void setOption(String key, String value);
AMQShortString getDefaultQueueExchangeName();
AMQShortString getDefaultTopicExchangeName();
AMQShortString getTemporaryQueueExchangeName();
AMQShortString getTemporaryTopicExchangeName();
}
|
