/* * * 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 *
* 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