svn commit: r1632004 - /qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
Author: rhs
Date: Wed Oct 15 12:45:47 2014
New Revision: 1632004
URL: http://svn.apache.org/r1632004
Log:
PROTON-714: don't overflow the input buffer
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java?rev=1632004r1=1632003r2=1632004view=diff
==
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/ssl/SimpleSslTransportWrapper.java
Wed Oct 15 12:45:47 2014
@@ -125,7 +125,13 @@ public class SimpleSslTransportWrapper i
} else {
ByteBuffer tail = _underlyingInput.tail();
_decodedInputBuffer.flip();
+int limit = _decodedInputBuffer.limit();
+int overflow = _decodedInputBuffer.remaining() - capacity;
+if (overflow 0) {
+_decodedInputBuffer.limit(limit - overflow);
+}
tail.put(_decodedInputBuffer);
+_decodedInputBuffer.limit(limit);
_decodedInputBuffer.compact();
_underlyingInput.process();
capacity = _underlyingInput.capacity();
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1632092 - in /qpid/proton/trunk/proton-c/src: posix/io.c windows/io.c
Author: rhs
Date: Wed Oct 15 15:31:20 2014
New Revision: 1632092
URL: http://svn.apache.org/r1632092
Log:
PROTON-712: check getprotobyname for NULL return value (patch from Sahir Hoda)
Modified:
qpid/proton/trunk/proton-c/src/posix/io.c
qpid/proton/trunk/proton-c/src/windows/io.c
Modified: qpid/proton/trunk/proton-c/src/posix/io.c
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/posix/io.c?rev=1632092r1=1632091r2=1632092view=diff
==
--- qpid/proton/trunk/proton-c/src/posix/io.c (original)
+++ qpid/proton/trunk/proton-c/src/posix/io.c Wed Oct 15 15:31:20 2014
@@ -228,7 +228,11 @@ ssize_t pn_send(pn_io_t *io, pn_socket_t
}
static inline int pn_create_socket(int af) {
- return socket(af, SOCK_STREAM, getprotobyname(tcp)-p_proto);
+ struct protoent * pe_tcp = getprotobyname(tcp);
+ if (pe_tcp == NULL) {
+return -1;
+ }
+ return socket(af, SOCK_STREAM, pe_tcp-p_proto);
}
#elif defined(SO_NOSIGPIPE)
ssize_t pn_send(pn_io_t *io, pn_socket_t socket, const void *buf, size_t size)
{
@@ -238,7 +242,13 @@ ssize_t pn_send(pn_io_t *io, pn_socket_t
}
static inline int pn_create_socket(int af) {
- int sock = socket(af, SOCK_STREAM, getprotobyname(tcp)-p_proto);
+ struct protoent * pe_tcp;
+ int sock;
+ pe_tcp = getprotobyname(tcp);
+ if (pe_tcp == NULL) {
+return -1;
+ }
+ sock = socket(af, SOCK_STREAM, pe_tcp-p_proto);
if (sock == -1) return sock;
int optval = 1;
Modified: qpid/proton/trunk/proton-c/src/windows/io.c
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/windows/io.c?rev=1632092r1=1632091r2=1632092view=diff
==
--- qpid/proton/trunk/proton-c/src/windows/io.c (original)
+++ qpid/proton/trunk/proton-c/src/windows/io.c Wed Oct 15 15:31:20 2014
@@ -302,7 +302,11 @@ pn_socket_t pn_accept(pn_io_t *io, pn_so
}
static inline pn_socket_t pni_create_socket() {
- return socket(AF_INET, SOCK_STREAM, getprotobyname(tcp)-p_proto);
+ struct protoent * pe_tcp = getprotobyname(tcp);
+ if (pe_tcp == NULL) {
+return -1;
+ }
+ return socket(AF_INET, SOCK_STREAM, pe_tcp-p_proto);
}
ssize_t pn_send(pn_io_t *io, pn_socket_t sockfd, const void *buf, size_t len) {
@@ -375,8 +379,13 @@ static void configure_pipe_socket(pn_io_
static int pni_socket_pair (pn_io_t *io, SOCKET sv[2]) {
// no socketpair on windows. provide pipe() semantics using sockets
+ struct protoent * pe_tcp = getprotobyname(tcp);
+ if (pe_tcp == NULL) {
+perror(getprotobyname);
+return -1;
+ }
- SOCKET sock = socket(AF_INET, SOCK_STREAM, getprotobyname(tcp)-p_proto);
+ SOCKET sock = socket(AF_INET, SOCK_STREAM, pe_tcp-p_proto);
if (sock == INVALID_SOCKET) {
perror(socket);
return -1;
@@ -407,7 +416,7 @@ static int pni_socket_pair (pn_io_t *io,
return -1;
}
- if ((sv[1] = socket(AF_INET, SOCK_STREAM, getprotobyname(tcp)-p_proto))
== INVALID_SOCKET) {
+ if ((sv[1] = socket(AF_INET, SOCK_STREAM, pe_tcp-p_proto)) ==
INVALID_SOCKET) {
perror(sock1);
closesocket(sock);
return -1;
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1632091 - /qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java
Author: robbie Date: Wed Oct 15 15:31:18 2014 New Revision: 1632091 URL: http://svn.apache.org/r1632091 Log: PROTON-715: subtract 1 when setting delivery-count header based on JMSXDeliveryCount during outbound Native transformation Modified: qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java Modified: qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java URL: http://svn.apache.org/viewvc/qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java?rev=1632091r1=1632090r2=1632091view=diff == --- qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java (original) +++ qpid/proton/trunk/contrib/proton-jms/src/main/java/org/apache/qpid/proton/jms/AMQPNativeOutboundTransformer.java Wed Oct 15 15:31:18 2014 @@ -81,7 +81,9 @@ public class AMQPNativeOutboundTransform } // Update the DeliveryCount header... -amqp.getHeader().setDeliveryCount(new UnsignedInteger(count)); +// The AMQP delivery-count field only includes prior failed delivery attempts, +// whereas JMSXDeliveryCount includes the first/current delivery attempt. Subtract 1. +amqp.getHeader().setDeliveryCount(new UnsignedInteger(count - 1)); // Re-encode... ByteBuffer buffer = ByteBuffer.wrap(new byte[1024*4]); - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1632098 - in /qpid/proton/trunk/proton-c: include/proton/driver.h src/posix/driver.c src/windows/driver.c
Author: rhs
Date: Wed Oct 15 15:47:26 2014
New Revision: 1632098
URL: http://svn.apache.org/r1632098
Log:
PROTON-708: changed pn_driver_error to return the pn_error_t
Modified:
qpid/proton/trunk/proton-c/include/proton/driver.h
qpid/proton/trunk/proton-c/src/posix/driver.c
qpid/proton/trunk/proton-c/src/windows/driver.c
Modified: qpid/proton/trunk/proton-c/include/proton/driver.h
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/include/proton/driver.h?rev=1632098r1=1632097r2=1632098view=diff
==
--- qpid/proton/trunk/proton-c/include/proton/driver.h (original)
+++ qpid/proton/trunk/proton-c/include/proton/driver.h Wed Oct 15 15:47:26 2014
@@ -73,13 +73,20 @@ PN_EXTERN pn_driver_t *pn_driver(void);
*/
PN_EXTERN int pn_driver_errno(pn_driver_t *d);
-/** Return the most recent error text for d.
+/** Get additional error information associated with the driver.
+ *
+ * Whenever a driver operation fails, additional error information can
+ * be obtained using this function. The error object that is returned
+ * may also be used to clear the error condition.
+ *
+ * The pointer returned by this operation is valid until the
+ * driver object is freed.
*
* @param[in] d the driver
*
- * @return the most recent error text for d
+ * @return the driver's error object
*/
-PN_EXTERN const char *pn_driver_error(pn_driver_t *d);
+PN_EXTERN pn_error_t *pn_driver_error(pn_driver_t *d);
/** Set the tracing level for the given driver.
*
Modified: qpid/proton/trunk/proton-c/src/posix/driver.c
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/posix/driver.c?rev=1632098r1=1632097r2=1632098view=diff
==
--- qpid/proton/trunk/proton-c/src/posix/driver.c (original)
+++ qpid/proton/trunk/proton-c/src/posix/driver.c Wed Oct 15 15:47:26 2014
@@ -576,12 +576,14 @@ pn_driver_t *pn_driver()
int pn_driver_errno(pn_driver_t *d)
{
- return d ? pn_error_code(d-error) : PN_ARG_ERR;
+ assert(d);
+ return pn_error_code(d-error);
}
-const char *pn_driver_error(pn_driver_t *d)
+pn_error_t *pn_driver_error(pn_driver_t *d)
{
- return d ? pn_error_text(d-error) : NULL;
+ assert(d);
+ return d-error;
}
void pn_driver_trace(pn_driver_t *d, pn_trace_t trace)
Modified: qpid/proton/trunk/proton-c/src/windows/driver.c
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/windows/driver.c?rev=1632098r1=1632097r2=1632098view=diff
==
--- qpid/proton/trunk/proton-c/src/windows/driver.c (original)
+++ qpid/proton/trunk/proton-c/src/windows/driver.c Wed Oct 15 15:47:26 2014
@@ -712,12 +712,14 @@ pn_driver_t *pn_driver()
int pn_driver_errno(pn_driver_t *d)
{
- return d ? pn_error_code(d-error) : PN_ARG_ERR;
+ assert(d);
+ return pn_error_code(d-error);
}
-const char *pn_driver_error(pn_driver_t *d)
+pn_error_t *pn_driver_error(pn_driver_t *d)
{
- return d ? pn_error_text(d-error) : NULL;
+ assert(d);
+ return d-error;
}
void pn_driver_trace(pn_driver_t *d, pn_trace_t trace)
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
[3/3] git commit: start testing the message transformation bits.
start testing the message transformation bits.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/a088d998
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/a088d998
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/a088d998
Branch: refs/heads/master
Commit: a088d99805ef6ede9eb321009324ad3441d2c6ab
Parents: a757bab
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 11:45:48 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 11:45:48 2014 -0400
--
.../message/JmsMessageTransformationTest.java | 35
1 file changed, 35 insertions(+)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/a088d998/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
--
diff --git
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
index 84c294f..8dc485b 100644
---
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
+++
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
@@ -19,6 +19,7 @@ package org.apache.qpid.jms.message;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNotSame;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertSame;
import static org.junit.Assert.assertTrue;
@@ -34,6 +35,7 @@ import javax.jms.Topic;
import org.apache.qpid.jms.JmsConnection;
import org.apache.qpid.jms.JmsDestination;
import org.apache.qpid.jms.JmsTopic;
+import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFacade;
import org.junit.Test;
import org.mockito.Mockito;
@@ -49,6 +51,39 @@ public class JmsMessageTransformationTest {
new JmsMessageTransformation();
}
+//-- Test Message Transformation
-//
+
+@Test
+public void testTransformJmsMessageCopies() throws JMSException {
+JmsMessage source = new JmsMessage(new JmsDefaultMessageFacade());
+
+source.setJMSMessageID(ID:CONNECTION:1:1);
+
+JmsMessage copy =
JmsMessageTransformation.transformMessage(createMockJmsConnection(), source);
+assertNotNull(copy.getJMSMessageID());
+assertEquals(source, copy);
+assertNotSame(source, copy);
+}
+
+//-- Test Generic Property Copy
--//
+
+@Test
+public void testJMSMessagePropertiesAreCopied() throws JMSException {
+JmsMessage source = new JmsMessage(new JmsDefaultMessageFacade());
+JmsMessage target = new JmsMessage(new JmsDefaultMessageFacade());
+
+source.setJMSType(text/test);
+
+source.setBooleanProperty(boolValue, true);
+source.setStringProperty(stringValue, foo);
+
+JmsMessageTransformation.copyProperties(createMockJmsConnection(),
source, target);
+
+assertEquals(true, target.getBooleanProperty(boolValue));
+assertEquals(foo, target.getStringProperty(stringValue));
+assertEquals(text/test, target.getJMSType());
+}
+
//-- Test Destination Transformation
-//
@Test
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
[1/3] git commit: Complete path coverage of destination transformation method.
Repository: qpid-jms
Updated Branches:
refs/heads/master a0f228bad - a088d9980
Complete path coverage of destination transformation method.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/4d3ea7a1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/4d3ea7a1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/4d3ea7a1
Branch: refs/heads/master
Commit: 4d3ea7a1422bf710440f9a291832d05c7f871335
Parents: a0f228b
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 09:43:04 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 09:43:04 2014 -0400
--
.../message/JmsMessageTransformationTest.java | 89 +---
1 file changed, 76 insertions(+), 13 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/4d3ea7a1/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
--
diff --git
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
index 3904439..84c294f 100644
---
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
+++
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
@@ -19,6 +19,7 @@ package org.apache.qpid.jms.message;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertSame;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
@@ -51,6 +52,12 @@ public class JmsMessageTransformationTest {
//-- Test Destination Transformation
-//
@Test
+public void testTransformNullDestinationNoExceptions() throws JMSException
{
+JmsDestination transformed =
JmsMessageTransformation.transformDestination(createMockJmsConnection(), null);
+assertNull(transformed);
+}
+
+@Test
public void testPlainDestinationThrowsJMSEx() throws JMSException {
ForeignDestination destination = new
ForeignDestination(DESTINATION_NAME);
try {
@@ -71,6 +78,43 @@ public class JmsMessageTransformationTest {
}
@Test
+public void testCompositeTopicAndQueueDestinationNoNameThrowsJMSEx()
throws JMSException {
+ForeignTopicAndQueue destination = new
ForeignTopicAndQueue(DESTINATION_NAME);
+destination.setReturnQueueName(false);
+destination.setReturnTopicName(false);
+
+try {
+
JmsMessageTransformation.transformDestination(createMockJmsConnection(),
destination);
+fail(Should have thrown an JMSException);
+} catch (JMSException ex) {
+}
+}
+
+@Test
+public void testTransformCompositeDestinationFromForeignTopic() throws
JMSException {
+ForeignTopicAndQueue destination = new
ForeignTopicAndQueue(DESTINATION_NAME);
+destination.setReturnQueueName(false);
+
+JmsDestination transformed =
JmsMessageTransformation.transformDestination(createMockJmsConnection(),
destination);
+assertNotNull(transformed);
+assertTrue(transformed.isTopic());
+assertFalse(transformed.isTemporary());
+assertEquals(DESTINATION_NAME, transformed.getName());
+}
+
+@Test
+public void testTransformCompositeDestinationFromForeignQueue() throws
JMSException {
+ForeignTopicAndQueue destination = new
ForeignTopicAndQueue(DESTINATION_NAME);
+destination.setReturnTopicName(false);
+
+JmsDestination transformed =
JmsMessageTransformation.transformDestination(createMockJmsConnection(),
destination);
+assertNotNull(transformed);
+assertTrue(transformed.isQueue());
+assertFalse(transformed.isTemporary());
+assertEquals(DESTINATION_NAME, transformed.getName());
+}
+
+@Test
public void testJmsDestinationIsNotTransformed() throws JMSException {
JmsDestination destination = new JmsTopic(DESTINATION_NAME);
JmsDestination transformed =
JmsMessageTransformation.transformDestination(createMockJmsConnection(),
destination);
@@ -164,53 +208,72 @@ public class JmsMessageTransformationTest {
}
}
-private class ForeignTopicAndQueue extends ForeignDestination implements
Queue, Topic {
+private class ForeignTemporaryQueue extends ForeignQueue implements
TemporaryQueue {
-public ForeignTopicAndQueue(String name) {
+public ForeignTemporaryQueue(String name) {
super(name);
}
[2/3] git commit: Create a raw Message type, not a TextMessage
Create a raw Message type, not a TextMessage
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/a757bab4
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/a757bab4
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/a757bab4
Branch: refs/heads/master
Commit: a757bab4ca103ad6bc3887ebe47a21bbbede6be4
Parents: 4d3ea7a
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 11:45:23 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 11:45:23 2014 -0400
--
.../java/org/apache/qpid/jms/message/JmsMessageTransformation.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/a757bab4/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
--
diff --git
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
index c160cc8..cb82492 100644
---
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
+++
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
@@ -165,7 +165,7 @@ public final class JmsMessageTransformation {
msg.setText(textMsg.getText());
activeMessage = msg;
} else {
-activeMessage = factory.createTextMessage();
+activeMessage = factory.createMessage();
}
copyProperties(connection, message, activeMessage);
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1632102 - /qpid/trunk/qpid/java/perftests/etc/chartdefs/
Author: macbean
Date: Wed Oct 15 15:57:25 2014
New Revision: 1632102
URL: http://svn.apache.org/r1632102
Log:
QPID-6138: [Java Perf Tests] Update perf test chart def descriptions
Modified:
qpid/trunk/qpid/java/perftests/etc/chartdefs/1001-MessageSize-Transient-ByteSec.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1002-MessageSize-Persistent-ByteSec.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1003-MessageSize-Transient-MsgSec.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1004-MessageSize-Persistent-MsgSec.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1011-VaryingNumberOfProducers-AutoAck.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1012-VaryingNumberOfConsumers-AutoAck.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1015-VaryingNumberOfProducers-SessionTrans.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1016-VaryingNumberOfConsumers-SessionTrans.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1021-AcknowledgementModes-Persistent.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1022-AcknowledgementModes-Transient.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1030-BatchSize-Equal.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1031-BatchSize-Unequal.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1040-QueueTypes.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1050-VaryingNumberOfProducerSessionsSingleConnection.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1300-QueueConsumersWithNonOverlappingSelectors-Transient.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1301-QueueConsumersWithNonOverlappingSelectors-Persistent.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1302-QueueConsumersWithOverlappingSelectors-Transient.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1303-QueueConsumersWithOverlappingSelectors-Persistent.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1500-Topic-NumberOfConsumers.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1501-Topic-NumberOfTopics.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1502-Topic-Persistence.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/1503-Topic-AckModes.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/2001-Latency-MessageSize-Transient.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/2002-Latency-MessageSize-Persistent.chartdef
qpid/trunk/qpid/java/perftests/etc/chartdefs/2031-Latency-VaryingNumberOfParticipants.chartdef
Modified:
qpid/trunk/qpid/java/perftests/etc/chartdefs/1001-MessageSize-Transient-ByteSec.chartdef
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/etc/chartdefs/1001-MessageSize-Transient-ByteSec.chartdef?rev=1632102r1=1632101r2=1632102view=diff
==
---
qpid/trunk/qpid/java/perftests/etc/chartdefs/1001-MessageSize-Transient-ByteSec.chartdef
(original)
+++
qpid/trunk/qpid/java/perftests/etc/chartdefs/1001-MessageSize-Transient-ByteSec.chartdef
Wed Oct 15 15:57:25 2014
@@ -20,7 +20,7 @@
chartType=XYLINE
chartTitle=Impact of Message Size Bytes/S
chartSubtitle=Transient messages
-chartDescription=1P 1C, transient, auto-ack, with message payload between
256-262144 bytes ${baselineName}, single queue.
+chartDescription=1P 1C, single queue, transient, auto-ack, with message
payload between 256-262144 bytes ${baselineName}.
xAxisTitle=Message Size (B)
yAxisTitle=Throughput (KB/s)
Modified:
qpid/trunk/qpid/java/perftests/etc/chartdefs/1002-MessageSize-Persistent-ByteSec.chartdef
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/etc/chartdefs/1002-MessageSize-Persistent-ByteSec.chartdef?rev=1632102r1=1632101r2=1632102view=diff
==
---
qpid/trunk/qpid/java/perftests/etc/chartdefs/1002-MessageSize-Persistent-ByteSec.chartdef
(original)
+++
qpid/trunk/qpid/java/perftests/etc/chartdefs/1002-MessageSize-Persistent-ByteSec.chartdef
Wed Oct 15 15:57:25 2014
@@ -20,7 +20,7 @@
chartType=XYLINE
chartTitle=Impact of Message Size Bytes/S
chartSubtitle=Persistent messages
-chartDescription=1P 1C, persistent, auto-ack, with message payload between
256-262144 bytes, single queue.
+chartDescription=1P 1C, single queue, persistent, session-transacted, with
message payload between 256-262144 bytes.
xAxisTitle=Message Size (B)
yAxisTitle=Throughput (KB/s)
Modified:
qpid/trunk/qpid/java/perftests/etc/chartdefs/1003-MessageSize-Transient-MsgSec.chartdef
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/etc/chartdefs/1003-MessageSize-Transient-MsgSec.chartdef?rev=1632102r1=1632101r2=1632102view=diff
==
---
qpid/trunk/qpid/java/perftests/etc/chartdefs/1003-MessageSize-Transient-MsgSec.chartdef
git commit: Clean up comments and API documentation.
Repository: qpid-jms
Updated Branches:
refs/heads/master a088d9980 - c6618625d
Clean up comments and API documentation.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/c6618625
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/c6618625
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/c6618625
Branch: refs/heads/master
Commit: c6618625d22927bd27902229ff6dccd8d6ff49e6
Parents: a088d99
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 12:59:59 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 12:59:59 2014 -0400
--
.../jms/message/JmsMessageTransformation.java | 63 +++-
1 file changed, 34 insertions(+), 29 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/c6618625/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
--
diff --git
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
index cb82492..9dfd85b 100644
---
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
+++
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
@@ -97,12 +97,14 @@ public final class JmsMessageTransformation {
* provider.
*
* @param message
- *- Message to be converted into Jms's implementation.
+ *Message to be converted into Jms's implementation.
* @param connection
- * @return JmsMessage - Jms's implementation object of the
- * message.
- * @throws JMSException
- * if an error occurs
+ *The JmsConnection where this transformation is being initiated.
+ *
+ * @return JmsMessage
+ * The client's implementation object for the incoming message.
+ *
+ * @throws JMSException if an error occurs during the copy.
*/
public static JmsMessage transformMessage(JmsConnection connection,
Message message) throws JMSException {
if (message instanceof JmsMessage) {
@@ -117,12 +119,11 @@ public final class JmsMessageTransformation {
JmsBytesMessage msg = factory.createBytesMessage();
try {
for (;;) {
-// Reads a byte from the message stream until the
stream
-// is empty
+// Reads a byte from the message stream until the
stream is empty
msg.writeByte(bytesMsg.readByte());
}
} catch (MessageEOFException e) {
-// if an end of message stream as expected
+// Indicates all the bytes have been read from the source.
} catch (JMSException e) {
}
@@ -154,7 +155,7 @@ public final class JmsMessageTransformation {
msg.writeObject(obj);
}
} catch (MessageEOFException e) {
-// if an end of message stream as expected
+// Indicates all the stream values have been read from the
source.
} catch (JMSException e) {
}
@@ -175,33 +176,37 @@ public final class JmsMessageTransformation {
}
/**
- * Copies the standard JMS and user defined properties from the givem
- * message to the specified message
+ * Copies the standard JMS and user defined properties from the given
source
+ * message to the specified target message. The copy can only handle the
JMS
+ * specific message properties and known JMS Headers, any headers that are
+ * specific to the foreign message may be lost if not returned directly via
+ * the codepropertyNames/code method.
*
- * @param fromMessage
+ * @param source
*the message to take the properties from
- * @param toMessage
+ * @param target
*the message to add the properties to
- * @throws JMSException
+ *
+ * @throws JMSException if an error occurs during the copy of message
properties.
*/
-public static void copyProperties(JmsConnection connection, Message
fromMessage, Message toMessage) throws JMSException {
-toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
-toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
-toMessage.setJMSReplyTo(transformDestination(connection,
fromMessage.getJMSReplyTo()));
-toMessage.setJMSDestination(transformDestination(connection,
fromMessage.getJMSDestination()));
-
svn commit: r1632169 - /qpid/dispatch/trunk/src/python_embedded.c
Author: tross
Date: Wed Oct 15 20:01:16 2014
New Revision: 1632169
URL: http://svn.apache.org/r1632169
Log:
NO-JIRA - Use empty-list encoding for zero-length lists from Python.
Modified:
qpid/dispatch/trunk/src/python_embedded.c
Modified: qpid/dispatch/trunk/src/python_embedded.c
URL:
http://svn.apache.org/viewvc/qpid/dispatch/trunk/src/python_embedded.c?rev=1632169r1=1632168r2=1632169view=diff
==
--- qpid/dispatch/trunk/src/python_embedded.c (original)
+++ qpid/dispatch/trunk/src/python_embedded.c Wed Oct 15 20:01:16 2014
@@ -150,22 +150,30 @@ qd_error_t qd_py_to_composed(PyObject *v
else if (PyList_Check(value)) {
Py_ssize_t count = PyList_Size(value);
-qd_compose_start_list(field);
-for (Py_ssize_t idx = 0; idx count; idx++) {
-PyObject *item = PyList_GetItem(value, idx); QD_ERROR_PY_RET();
-qd_py_to_composed(item, field); QD_ERROR_RET();
+if (count == 0)
+qd_compose_empty_list(field);
+else {
+qd_compose_start_list(field);
+for (Py_ssize_t idx = 0; idx count; idx++) {
+PyObject *item = PyList_GetItem(value, idx); QD_ERROR_PY_RET();
+qd_py_to_composed(item, field); QD_ERROR_RET();
+}
+qd_compose_end_list(field);
}
-qd_compose_end_list(field);
}
else if (PyTuple_Check(value)) {
Py_ssize_t count = PyTuple_Size(value);
-qd_compose_start_list(field);
-for (Py_ssize_t idx = 0; idx count; idx++) {
-PyObject *item = PyTuple_GetItem(value, idx); QD_ERROR_PY_RET();
-qd_py_to_composed(item, field); QD_ERROR_RET();
+if (count == 0)
+qd_compose_empty_list(field);
+else {
+qd_compose_start_list(field);
+for (Py_ssize_t idx = 0; idx count; idx++) {
+PyObject *item = PyTuple_GetItem(value, idx);
QD_ERROR_PY_RET();
+qd_py_to_composed(item, field); QD_ERROR_RET();
+}
+qd_compose_end_list(field);
}
-qd_compose_end_list(field);
}
else {
PyObject *type=0, *typestr=0, *repr=0;
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1632175 - /qpid/proton/trunk/proton-c/src/ssl/openssl.c
Author: kgiusti
Date: Wed Oct 15 20:46:42 2014
New Revision: 1632175
URL: http://svn.apache.org/r1632175
Log:
PROTON-716: reject connections using SSLv3 - it is insecure
Modified:
qpid/proton/trunk/proton-c/src/ssl/openssl.c
Modified: qpid/proton/trunk/proton-c/src/ssl/openssl.c
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-c/src/ssl/openssl.c?rev=1632175r1=1632174r2=1632175view=diff
==
--- qpid/proton/trunk/proton-c/src/ssl/openssl.c (original)
+++ qpid/proton/trunk/proton-c/src/ssl/openssl.c Wed Oct 15 20:46:42 2014
@@ -451,9 +451,13 @@ pn_ssl_domain_t *pn_ssl_domain( pn_ssl_m
domain-ref_count = 1;
domain-mode = mode;
+
+ // enable all supported protocol versions, then explicitly disable the
+ // known vulnerable ones. This should allow us to use the latest version
+ // of the TLS standard that the installed library supports.
switch(mode) {
case PN_SSL_MODE_CLIENT:
-domain-ctx = SSL_CTX_new(TLSv1_client_method());
+domain-ctx = SSL_CTX_new(SSLv23_client_method()); // and TLSv1+
if (!domain-ctx) {
_log_ssl_error( Unable to initialize OpenSSL context.\n);
free(domain);
@@ -462,20 +466,21 @@ pn_ssl_domain_t *pn_ssl_domain( pn_ssl_m
break;
case PN_SSL_MODE_SERVER:
-domain-ctx = SSL_CTX_new(SSLv23_server_method());
+domain-ctx = SSL_CTX_new(SSLv23_server_method()); // and TLSv1+
if (!domain-ctx) {
_log_ssl_error(Unable to initialize OpenSSL context.\n);
free(domain);
return NULL;
}
-SSL_CTX_set_options(domain-ctx, SSL_OP_NO_SSLv2); // v2 is insecure
break;
default:
-_log_error(Invalid valid for pn_ssl_mode_t: %d\n, mode);
+_log_error(Invalid value for pn_ssl_mode_t: %d\n, mode);
free(domain);
return NULL;
}
+ const long reject_insecure = SSL_OP_NO_SSLv2 | SSL_OP_NO_SSLv3;
+ SSL_CTX_set_options(domain-ctx, reject_insecure);
// by default, allow anonymous ciphers so certificates are not required 'out
of the box'
if (!SSL_CTX_set_cipher_list( domain-ctx, CIPHERS_ANONYMOUS )) {
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
svn commit: r1632176 - in /qpid/trunk/qpid/doc/book/src: java-broker/management/managing/ jms-client-0-8/
Author: kwall Date: Wed Oct 15 20:54:34 2014 New Revision: 1632176 URL: http://svn.apache.org/r1632176 Log: QPID-6108: [Java Documentation] Fix table error causing fop error whilst generating pdf Added: qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualhostNodes.xml - copied, changed from r1632102, qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualHostNodes.xml Removed: qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualHostNodes.xml Modified: qpid/trunk/qpid/doc/book/src/jms-client-0-8/JMS-Client-Connection-URL.xml Copied: qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualhostNodes.xml (from r1632102, qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualHostNodes.xml) URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualhostNodes.xml?p2=qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualhostNodes.xmlp1=qpid/trunk/qpid/doc/book/src/java-broker/management/managing/Java-Broker-Management-Managing-VirtualHostNodes.xmlr1=1632102r2=1632176rev=1632176view=diff == (empty) Modified: qpid/trunk/qpid/doc/book/src/jms-client-0-8/JMS-Client-Connection-URL.xml URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/doc/book/src/jms-client-0-8/JMS-Client-Connection-URL.xml?rev=1632176r1=1632175r2=1632176view=diff == --- qpid/trunk/qpid/doc/book/src/jms-client-0-8/JMS-Client-Connection-URL.xml (original) +++ qpid/trunk/qpid/doc/book/src/jms-client-0-8/JMS-Client-Connection-URL.xml Wed Oct 15 20:54:34 2014 @@ -149,13 +149,11 @@ row id=JMS-Client-0-8-Connection-URL-ConnectionOptions-CompressMessages entrycompressMessages/entry entryBoolean/entry - entryfalse/entry entryparaControls whether the client will compress messages before they they are sent./para/entry /row row id=JMS-Client-0-8-Connection-URL-ConnectionOptions-MessageCompressionThresholdSize entrymessageCompressionThresholdSize/entry entryInteger/entry - entry102400/entry entryparaThe payload size beyond which the client will start to compress message payloads./para/entry /row /tbody - To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
[1/2] git commit: Add a set of JMS Message implementations that can be used to test support for Foreign JMS Types.
Repository: qpid-jms
Updated Branches:
refs/heads/master c6618625d - 6a221b168
Add a set of JMS Message implementations that can be used to test
support for Foreign JMS Types.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/12cc2f37
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/12cc2f37
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/12cc2f37
Branch: refs/heads/master
Commit: 12cc2f37c03984817213ce1c9d03a0ceb2c7eca8
Parents: c661862
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 15:12:32 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 15:12:32 2014 -0400
--
.../message/JmsMessageTransformationTest.java | 13 +
.../message/foreign/ForeignJmsBytesMessage.java | 171
.../message/foreign/ForeignJmsMapMessage.java | 163 +++
.../jms/message/foreign/ForeignJmsMessage.java | 268 +++
.../foreign/ForeignJmsObjectMessage.java| 48
.../foreign/ForeignJmsStreamMessage.java| 156 +++
.../message/foreign/ForeignJmsTextMessage.java | 46
7 files changed, 865 insertions(+)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
--
diff --git
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
index 8dc485b..9893946 100644
---
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
+++
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
@@ -36,6 +36,8 @@ import org.apache.qpid.jms.JmsConnection;
import org.apache.qpid.jms.JmsDestination;
import org.apache.qpid.jms.JmsTopic;
import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFacade;
+import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFactory;
+import org.apache.qpid.jms.message.foreign.ForeignJmsMessage;
import org.junit.Test;
import org.mockito.Mockito;
@@ -65,6 +67,15 @@ public class JmsMessageTransformationTest {
assertNotSame(source, copy);
}
+@Test
+public void testBasicMessageTransformCreateNewMessage() throws
JMSException {
+ForeignJmsMessage foreignMessage = new ForeignJmsMessage();
+
+JmsMessage transformed =
JmsMessageTransformation.transformMessage(createMockJmsConnection(),
foreignMessage);
+assertNotSame(foreignMessage, transformed);
+assertFalse(transformed.equals(foreignMessage));
+}
+
//-- Test Generic Property Copy
--//
@Test
@@ -205,6 +216,8 @@ public class JmsMessageTransformationTest {
private JmsConnection createMockJmsConnection() {
JmsConnection connection = Mockito.mock(JmsConnection.class);
+Mockito.when(connection.getMessageFactory()).thenReturn(new
JmsDefaultMessageFactory());
+
return connection;
}
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/12cc2f37/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java
--
diff --git
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java
new file mode 100644
index 000..d8ea4be
--- /dev/null
+++
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/foreign/ForeignJmsBytesMessage.java
@@ -0,0 +1,171 @@
+/**
+ * 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.message.foreign;
+
+import javax.jms.BytesMessage;
+import javax.jms.JMSException;
+
+import org.apache.qpid.jms.message.JmsBytesMessage;
+import
[2/2] git commit: Test and cleanup the transformation of Foreign messages.
Test and cleanup the transformation of Foreign messages.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/6a221b16
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/6a221b16
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/6a221b16
Branch: refs/heads/master
Commit: 6a221b1686f454cbeb35092ae0baf9909faaca4e
Parents: 12cc2f3
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 17:24:29 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 17:24:29 2014 -0400
--
.../jms/message/JmsMessageTransformation.java | 2 -
.../message/JmsMessageTransformationTest.java | 199 ++-
2 files changed, 198 insertions(+), 3 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6a221b16/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
--
diff --git
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
index 9dfd85b..896bc6a 100644
---
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
+++
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsMessageTransformation.java
@@ -124,7 +124,6 @@ public final class JmsMessageTransformation {
}
} catch (MessageEOFException e) {
// Indicates all the bytes have been read from the source.
-} catch (JMSException e) {
}
activeMessage = msg;
@@ -156,7 +155,6 @@ public final class JmsMessageTransformation {
}
} catch (MessageEOFException e) {
// Indicates all the stream values have been read from the
source.
-} catch (JMSException e) {
}
activeMessage = msg;
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6a221b16/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
--
diff --git
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
index 9893946..f974e03 100644
---
a/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
+++
b/qpid-jms-client/src/test/java/org/apache/qpid/jms/message/JmsMessageTransformationTest.java
@@ -27,6 +27,7 @@ import static org.junit.Assert.fail;
import javax.jms.Destination;
import javax.jms.JMSException;
+import javax.jms.MessageEOFException;
import javax.jms.Queue;
import javax.jms.TemporaryQueue;
import javax.jms.TemporaryTopic;
@@ -37,7 +38,12 @@ import org.apache.qpid.jms.JmsDestination;
import org.apache.qpid.jms.JmsTopic;
import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFacade;
import org.apache.qpid.jms.message.facade.defaults.JmsDefaultMessageFactory;
+import org.apache.qpid.jms.message.foreign.ForeignJmsBytesMessage;
+import org.apache.qpid.jms.message.foreign.ForeignJmsMapMessage;
import org.apache.qpid.jms.message.foreign.ForeignJmsMessage;
+import org.apache.qpid.jms.message.foreign.ForeignJmsObjectMessage;
+import org.apache.qpid.jms.message.foreign.ForeignJmsStreamMessage;
+import org.apache.qpid.jms.message.foreign.ForeignJmsTextMessage;
import org.junit.Test;
import org.mockito.Mockito;
@@ -68,7 +74,7 @@ public class JmsMessageTransformationTest {
}
@Test
-public void testBasicMessageTransformCreateNewMessage() throws
JMSException {
+public void testForeignMessageTransformCreateNewMessage() throws
JMSException {
ForeignJmsMessage foreignMessage = new ForeignJmsMessage();
JmsMessage transformed =
JmsMessageTransformation.transformMessage(createMockJmsConnection(),
foreignMessage);
@@ -76,6 +82,197 @@ public class JmsMessageTransformationTest {
assertFalse(transformed.equals(foreignMessage));
}
+@Test
+public void testEmptyForeignBytesMessageTransformCreateNewMessage() throws
JMSException {
+ForeignJmsBytesMessage foreignMessage = new ForeignJmsBytesMessage();
+
+JmsMessage transformed =
JmsMessageTransformation.transformMessage(createMockJmsConnection(),
foreignMessage);
+assertNotSame(foreignMessage, transformed);
+assertFalse(transformed.equals(foreignMessage));
+
+assertTrue(transformed instanceof JmsBytesMessage);
+JmsBytesMessage message = (JmsBytesMessage) transformed;
+message.reset();
+
svn commit: r1632181 [3/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Modified: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-Ports.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-Ports.html?rev=1632181r1=1632180r2=1632181view=diff == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-Ports.html (original) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-Ports.html Wed Oct 15 21:29:55 2014 @@ -21,7 +21,7 @@ -- html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en head -title4.5.#160;Ports - Apache Qpid#8482;/title +title4.8.#160;Ports - Apache Qpid#8482;/title meta http-equiv=X-UA-Compatible content=IE=edge/ meta name=viewport content=width=device-width, initial-scale=1.0/ link rel=stylesheet href=/site.css type=text/css async=async/ @@ -106,19 +106,19 @@ /div div id=-middle class=panel -ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili4.5.#160;Ports/li/ul -div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=34.5.#160;Ports/th/trtrtd align=left width=20%a accesskey=p href=Java-Broker-Concepts-Queues.htmlPrev/a#160;/tdth align=center width=60%Chapter#160;4.#160;Concepts/thtd align=right width=20%#160;a accesskey=n href=Java-Broker-Concepts-Authentication-Providers.htmlNext/a/td/tr/tablehr //divdiv class=sectiondiv class=titlepagedivdivh2 class=titlea id=Java-Broker-Concepts-Ports/a4.5.#160;Ports/h2/div/div/divp -The Broker supports configuration of span class=emphasisemPorts/em/span to specify the particular AMQP messaging -and HTTP/JMX management connectivity it offers for use. -/pp -Each Port is configured with the particular span class=emphasisemProtocols/em/span and span class=emphasisemTransports/em/span it supports, as well as the span class=emphasisemAuthentication Provider/em/span to be used to authenticate connections. Where SSL is in use, the span class=emphasisemPort/em/span configuration also defines which span class=emphasisemKeystore/em/span to use and (where supported) which span class=emphasisemTrustStore(s)/em/span and whether Client Certificates should be requested/required. -/pp -Different span class=emphasisemPorts/em/span can support different protocols, and many span class=emphasisemPorts/em/span can be configured on the Broker./pp -The following AMQP protocols are currently supported by the Broker: -/pdiv class=itemizedlistul class=itemizedlist type=discli class=listitempspan class=emphasisemAMQP 0-8/em/span/p/lili class=listitempspan class=emphasisemAMQP 0-9/em/span/p/lili class=listitempspan class=emphasisemAMQP 0-9-1/em/span/p/lili class=listitempspan class=emphasisemAMQP 0-10/em/span/p/lili class=listitempspan class=emphasisemAMQP 1.0/em/span/p/li/ul/divp -/pp -Addittionally, HTTP and JMX ports can be configured for use by the associated management plugins. -/ppConfiguration details for the Ports are covered in a class=xref href=Java-Broker-Ports.html title=Chapter#160;6.#160;Broker PortsChapter#160;6, emBroker Ports/em/a./p/divdiv class=navfooterhr /table summary=Navigation footer width=100%trtd align=left width=40%a accesskey=p href=Java-Broker-Concepts-Queues.htmlPrev/a#160;/tdtd align=center width=20%a accesskey=u href=Java-Broker-Concepts.htmlUp/a/tdtd align=right width=40%#160;a accesskey=n href=Java-Broker-Concepts-Authentication-Providers.htmlNext/a/td/trtrtd align=left valign=top width=40%4.4.#160;Queues#160;/tdtd align=center width=20%a accesskey=h href=index.htmlHome/a/tdtd align=right valign=top width=40%#160;4.6.#160;Authentication Providers/td/tr/table/div/div +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili4.8.#160;Ports/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=34.8.#160;Ports/th/trtrtd align=left width=20%a accesskey=p href=Java-Broker-Concepts-Queues.htmlPrev/a#160;/tdth align=center width=60%Chapter#160;4.#160;Concepts/thtd align=right width=20%#160;a accesskey=n href=Java-Broker-Concepts-Authentication-Providers.htmlNext/a/td/tr/tablehr //divdiv class=sectiondiv class=titlepagedivdivh2 class=titlea id=Java-Broker-Concepts-Ports/a4.8.#160;Ports/h2/div/div/divp The Broker supports configuration of span class=emphasisemPorts/em/span to specify the particular +AMQP messaging and HTTP/JMX management connectivity it offers for use. /pp Each Port is configured
svn commit: r1632181 [4/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Modified: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-Backup.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-Backup.html?rev=1632181r1=1632180r2=1632181view=diff == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-Backup.html (original) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-Backup.html Wed Oct 15 21:29:55 2014 @@ -21,7 +21,7 @@ -- html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en head -title13.13.#160;Backups - Apache Qpid#8482;/title +title10.11.#160;Backups - Apache Qpid#8482;/title meta http-equiv=X-UA-Compatible content=IE=edge/ meta name=viewport content=width=device-width, initial-scale=1.0/ link rel=stylesheet href=/site.css type=text/css async=async/ @@ -106,12 +106,9 @@ /div div id=-middle class=panel -ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili13.13.#160;Backups/li/ul -div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=313.13.#160;Backups/th/trtrtd align=left width=20%a accesskey=p href=Java-Broker-High-Availability-Security.htmlPrev/a#160;/tdth align=center width=60%Chapter#160;13.#160;High Availability/thtd align=right width=20%#160;a accesskey=n href=Java-Broker-High-Availability-MigrationFromNonHA.htmlNext/a/td/tr/tablehr //divdiv class=sectiondiv class=titlepagedivdivh2 class=titlea id=Java-Broker-High-Availability-Backup/a13.13.#160;Backups/h2/div/div/divpIn order to protect the entire cluster from some cataclysms which might destroy all cluster nodes, -backups of the Master store should be taken on a regular basis./ppQpid Broker distribution includes the hot backup utility span class=emphasisembackup.sh/em/span which can be found at broker bin folder. - This utility can perform the backup when broker is running./ppspan class=emphasisembackup.sh/em/span script invokes code class=classnameorg.apache.qpid.server.store.berkeleydb.BDBBackup/code to do the job./ppYou can also run this class from command line like in an example below:/pdiv class=examplea id=idm233113748576/ap class=titlestrongExample#160;13.5.#160;Performing store backup by using code class=classnameBDBBackup/code class directly/strong/pdiv class=example-contentsspan class=commandstrong -java -cp qpid-bdbstore-0.29.jar org.apache.qpid.server.store.berkeleydb.BDBBackup -fromdir path/to/store/folder -todir path/to/backup/folder/strong/span/div/divbr class=example-break /pIn the example above BDBBackup utility is called from qpid-bdbstore-0.29.jar to backup the store at span class=emphasisempath/to/store/folder/em/span and copy store logs into span class=emphasisempath/to/backup/folder/em/span./ppLinux and Unix users can take advantage of span class=emphasisembackup.sh/em/span bash script by running this script in a similar way./pdiv class=examplea id=idm233113744560/ap class=titlestrongExample#160;13.6.#160;Performing store backup by using code class=classnamebackup.sh/code bash script/strong/pdiv class=example-contentsspan class=commandstrongbackup.sh -fromdir path/to/store/folder -todir path/to/backup/folder/strong/span/div/divbr class=example-break /div clas s=note style=margin-left: 0.5in; margin-right: 0.5in;h3 class=titleNote/h3pDo not forget to ensure that the Master store is being backed up, in the event the Node elected Master changes during - the lifecycle of the cluster./p/div/divdiv class=navfooterhr /table summary=Navigation footer width=100%trtd align=left width=40%a accesskey=p href=Java-Broker-High-Availability-Security.htmlPrev/a#160;/tdtd align=center width=20%a accesskey=u href=Java-Broker-High-Availability.htmlUp/a/tdtd align=right width=40%#160;a accesskey=n href=Java-Broker-High-Availability-MigrationFromNonHA.htmlNext/a/td/trtrtd align=left valign=top width=40%13.12.#160;Security#160;/tdtd align=center width=20%a accesskey=h href=index.htmlHome/a/tdtd align=right valign=top width=40%#160;13.14.#160;Migration of a non-HA store to HA/td/tr/table/div/div +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili10.11.#160;Backups/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=310.11.#160;Backups/th/trtrtd align=left width=20%a accesskey=p href=Java-Broker-High-Availability-Security.htmlPrev/a#160;/tdth align=center
svn commit: r1632181 [1/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Author: kwall Date: Wed Oct 15 21:29:55 2014 New Revision: 1632181 URL: http://svn.apache.org/r1632181 Log: NO-JIRA: Republish trunk java-broker/jms-client-08 documentation Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Appendix-Queue-Alerts.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Backup-And-Recovery-Virtualhost-Node.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Backup-And-Recovery-Virtualhost.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Backup-And-Recovery.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-Broker.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-RemoteReplicationNodes.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-Virtualhost-Nodes.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Concepts-Virtualhosts.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Configuring-And-Managing-Configuration-Initial-Config-Example.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-Behaviour.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-CreatingGroup.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-NodeOperations.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-OverviewOfHA.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-Reset-Group-Infomational.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Configuration-Properties.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Create-Initial-Config.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Initial-Config-Location.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Location.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Overwrite-Config-Store.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Type.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Installation-OptionalDependencies.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-AMQP-Intrinstic.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-JMX.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-QMF.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-REST-API.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-Web-Console.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Access-Control-Providers.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Authentication-Providers.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Broker.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Entities-Matrix.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Entities.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Exchanges.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Group-Providers.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Keystores.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Plugin-HTTP.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Plugins-JMX.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Ports.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Queues.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-RemoteReplicationNodes.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Truststores.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Virtualhost-Nodes.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Virtualhosts.html qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Miscellaneous-Installing-External-JDBC-Driver.html
svn commit: r1632181 [10/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/image
Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Truststores.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Truststores.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Truststores.html (added) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Truststores.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,147 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +title7.12.#160;Truststores - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili7.12.#160;Truststores/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=37.12.#160;Truststores/th/trtrtd align=left width=20%a accesskey=p
svn commit: r1632181 [2/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Backup-And-Recovery-Virtualhost.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Backup-And-Recovery-Virtualhost.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Backup-And-Recovery-Virtualhost.html (added) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Backup-And-Recovery-Virtualhost.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,145 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +title11.3.#160;Virtualhost - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili11.3.#160;Virtualhost/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=311.3.#160;Virtualhost/th/trtrtd align=left width=20%a accesskey=p
svn commit: r1632181 [5/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-OverviewOfHA.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-OverviewOfHA.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-OverviewOfHA.html (added) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-High-Availability-OverviewOfHA.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,161 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +title10.2.#160;Overview of HA within the Java Broker - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili10.2.#160;Overview of HA within the Java Broker/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=310.2.#160;Overview of HA within the Java
svn commit: r1632181 [9/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Group-Providers.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Group-Providers.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Group-Providers.html (added) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Managing-Group-Providers.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,136 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +title7.13.#160;Group Providers - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili7.13.#160;Group Providers/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=37.13.#160;Group Providers/th/trtrtd align=left width=20%a accesskey=p
svn commit: r1632181 [14/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/image
Modified: qpid/site/docs/releases/qpid-trunk/java-broker/book/index.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/index.html?rev=1632181r1=1632180r2=1632181view=diff == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/index.html (original) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/index.html Wed Oct 15 21:29:55 2014 @@ -107,16 +107,14 @@ div id=-middle class=panel ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/liliAMQP Messaging Broker (Java)/li/ul -div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=3AMQP Messaging Broker (Java)/th/trtrtd align=left width=20%#160;/tdth align=center width=60%#160;/thtd align=right width=20%#160;a accesskey=n href=Java-Broker-Introduction.htmlNext/a/td/tr/tablehr //divdiv class=bookdiv class=titlepagedivdivh1 class=titlea id=idm233123374768/aAMQP Messaging Broker (Java)/h1/div/divhr //divdiv class=tocpstrongTable of Contents/strong/pdl class=tocdtspan class=chaptera href=Java-Broker-Introduction.html1. Introduction/a/span/dtdtspan class=chaptera href=Java-Broker-Installation.html2. Installation/a/span/dtdddldtspan class=sectiona href=Java-Broker-Installation.html#Java-Broker-Installation-Introduction2.1. Introduction/a/span/dtdtspan class=sectiona href=Java-Bro ker-Installation-Prerequistes.html2.2. Prerequisites/a/span/dtdddldtspan class=sectiona href=Java-Broker-Installation-Prerequistes.html#Java-Broker-Installation-Prerequistes-Java2.2.1. Java Platform/a/span/dtdtspan class=sectiona href=Java-Broker-Installation-Prerequistes.html#Java-Broker-Installation-Prerequistes-Disk2.2.2. Disk/a/span/dtdtspan class=sectiona href=Java-Broker-Installation-Prerequistes.html#Java-Broker-Installation-Prerequistes-Memory2.2.3. Memory/a/span/dtdtspan class=sectiona href=Java-Broker-Installation-Prerequistes.html#Java-Broker-Installation-Prerequistes-OperatingSystemAccount2.2.4. Operating System Account/a/span/dt/dl/dddtspan class=sectiona href=Java-Broker-Installation-Download.html2.3. Download/a/span/dtdddldtspan class=sectiona href=Java-Broker-Installation-Download.html#Java-Broker-Installation-Download-Release2.3.1. Broker Release/a/span /dtdtspan class=sectiona href=Java-Broker-Installation-Download.html#Java-Broker-Installation-Download-OptionalDependencies2.3.2. Optional Dependencies/a/span/dt/dl/dddtspan class=sectiona href=Java-Broker-Installation-InstallationWindows.html2.4. Installation on Windows/a/span/dtdddldtspan class=sectiona href=Java-Broker-Installation-InstallationWindows.html#Java-Broker-Installation-InstallationWindows-SettingQPIDWORK2.4.1. Setting the working directory/a/span/dtdtspan class=sectiona href=Java-Broker-Installation-InstallationWindows.html#Java-Broker-Installation-InstallationWindows-OptionalDependencies2.4.2. Optional Dependencies/a/span/dt/dl/dddtspan class=sectiona href=Java-Broker-Installation-InstallationUnix.html2.5. Installation on UNIX platforms/a/span/dtdddldtspan class=sectiona href=Java-Broker-Installation-InstallationUnix.html#Java-Broker-Installation-InstallationUnix- SettingQPIDWORK2.5.1. Setting the working directory/a/span/dtdtspan class=sectiona href=Java-Broker-Installation-InstallationUnix.html#Java-Broker-Installation-InstallationUnix-OptionalDependencies2.5.2. Optional Dependencies/a/span/dt/dl/dd/dl/dddtspan class=chaptera href=Java-Broker-Getting-Started.html3. Getting Started/a/span/dtdddldtspan class=sectiona href=Java-Broker-Getting-Started.html#Java-Broker-Getting-Started-Introduction3.1. Introduction/a/span/dtdtspan class=sectiona href=Java-Broker-Getting-Started-Starting-Stopping-Windows.html3.2. Starting/Stopping the broker on Windows/a/span/dtdtspan class=sectiona href=Java-Broker-Getting-Started-Starting-Stopping-Unix.html3.3. Starting/Stopping the broker on Unix/a/span/dtdtspan class=sectiona href=Java-Broker-Getting-Started-LogFile.html3.4. Log file/a/span/dtdtspan class=sectiona href=Java-Broker-Getting -Started-CommandLine.html3.5. Using the command line/a/span/dt/dl/dddtspan class=chaptera href=Java-Broker-Concepts.html4. Concepts/a/span/dtdddldtspan class=sectiona href=Java-Broker-Concepts.html#Java-Broker-Concepts-Broker4.1. Broker/a/span/dtdtspan class=sectiona href=Java-Broker-Concepts-Virtual-Hosts.html4.2. Virtual Hosts/a/span/dtdtspan class=sectiona href=Java-Broker-Concepts-Exchanges.html4.3. Exchanges/a/span/dtdddldtspan class=sectiona href=Java-Broker-Concepts-Exchanges.html#Java-Broker-Concepts-Exchanges-Predeclared4.3.1. Predeclared Exchanges/a/span/dtdtspan class=sectiona href=Java-Broker-Concepts-Exchanges.html#Java-Broker-Concepts-Exchanges-Types4.3.2. Exchange Types/a/span/dtdtspan class=sectiona
svn commit: r1632181 [15/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/image
Added: qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Appendix-JMS-Extensions-Binding.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Appendix-JMS-Extensions-Binding.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Appendix-JMS-Extensions-Binding.html (added) +++ qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Appendix-JMS-Extensions-Binding.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,155 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +titleC.2.#160;Binding Management - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/jms-client-0-8/book/index.htmlQpid JMS Client for AMQP protocols 0-8, 0-9 and 0-9-1/a/liliC.2.#160;Binding Management/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=3C.2.#160;Binding
svn commit: r1632181 [11/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/image
Modified: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Runtime-Disk-Space-Management.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Runtime-Disk-Space-Management.html?rev=1632181r1=1632180r2=1632181view=diff == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Runtime-Disk-Space-Management.html (original) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Runtime-Disk-Space-Management.html Wed Oct 15 21:29:55 2014 @@ -21,7 +21,7 @@ -- html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en head -title12.2.#160;Disk Space Management - Apache Qpid#8482;/title +title9.2.#160;Disk Space Management - Apache Qpid#8482;/title meta http-equiv=X-UA-Compatible content=IE=edge/ meta name=viewport content=width=device-width, initial-scale=1.0/ link rel=stylesheet href=/site.css type=text/css async=async/ @@ -106,28 +106,23 @@ /div div id=-middle class=panel -ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili12.2.#160;Disk Space Management/li/ul -div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=312.2.#160;Disk Space Management/th/trtrtd align=left width=20%a accesskey=p href=Java-Broker-Runtime.htmlPrev/a#160;/tdth align=center width=60%Chapter#160;12.#160;Runtime/thtd align=right width=20%#160;a accesskey=n href=Java-Broker-Runtime-Producer-Transaction-Timeout.htmlNext/a/td/tr/tablehr //divdiv class=sectiondiv class=titlepagedivdivh2 class=titlea id=Java-Broker-Runtime-Disk-Space-Management/a12.2.#160;Disk Space Management/h2/div/div/divdiv class=sectiondiv class=titlepagedivdivh3 class=titlea id=Qpid-Producer-Flow-Control/a12.2.1.#160;Producer Flow Control/h3/div/div/divdiv class=sectiondiv class=titlepagedivdivh4 class=titlea id=Java-Broker-Runtime-Disk-Space-Management-Producer-Flow-Control-GeneralInf ormation/a12.2.1.1.#160;General Information/h4/div/div/divp -The Qpid 0.6 release introduced a simplistic producer-side flow control mechanism -into the Java Messaging Broker, causing producers to be flow-controlled when they -attempt to send messages to an overfull queue. Qpid 0.18 introduced a similar -mechanism triggered by an overfull persistent message store on a virtual host. -/p/divdiv class=sectiondiv class=titlepagedivdivh4 class=titlea id=Java-Broker-Runtime-Disk-Space-Management-Producer-Flow-Control-ServerConfiguration/a12.2.1.2.#160;Server Configuration/h4/div/div/divdiv class=sectiondiv class=titlepagedivdivh5 class=titlea id=idm233114441024/aConfiguring a Queue to use flow control/h5/div/div/divp +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili9.2.#160;Disk Space Management/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=39.2.#160;Disk Space Management/th/trtrtd align=left width=20%a accesskey=p href=Java-Broker-Runtime.htmlPrev/a#160;/tdth align=center width=60%Chapter#160;9.#160;Runtime/thtd align=right width=20%#160;a accesskey=n href=Java-Broker-Runtime-Producer-Transaction-Timeout.htmlNext/a/td/tr/tablehr //divdiv class=sectiondiv class=titlepagedivdivh2 class=titlea id=Java-Broker-Runtime-Disk-Space-Management/a9.2.#160;Disk Space Management/h2/div/div/divdiv class=sectiondiv class=titlepagedivdivh3 class=titlea id=Qpid-Producer-Flow-Control/a9.2.1.#160;Producer Flow Control/h3/div/div/divdiv class=sectiondiv class=titlepagedivdivh4 class=titlea id=Java-Broker-Runtime-Disk-Space-Management-Producer-Flow-Control-GeneralInforma tion/a9.2.1.1.#160;General Information/h4/div/div/divp +The Java Broker supports a flow control mechanism to which can be used to prevent either a single queue +or an entire virtualhost exceeding configured limits. These two mechanisms are described +next. +/p/divdiv class=sectiondiv class=titlepagedivdivh4 class=titlea id=Java-Broker-Runtime-Disk-Space-Management-Producer-Flow-Control-ServerConfiguration/a9.2.1.2.#160;Server Configuration/h4/div/div/divdiv class=sectiondiv class=titlepagedivdivh5 class=titlea id=idp1078384/aConfiguring a Queue to use flow control/h5/div/div/divp Flow control is enabled on a producer when it sends a message to a Queue which is overfull. The producer flow control will be rescinded when all Queues on which a producer is blocking become
svn commit: r1632181 [7/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-AMQP-Intrinstic.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-AMQP-Intrinstic.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-AMQP-Intrinstic.html (added) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel-AMQP-Intrinstic.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,138 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +title6.5.#160;AMQP Intrinstic Management - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili6.5.#160;AMQP Intrinstic Management/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=36.5.#160;AMQP Intrinstic Management/th/trtrtd align=left
svn commit: r1632181 [16/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/image
Modified:
qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Connection-URL.html
URL:
http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Connection-URL.html?rev=1632181r1=1632180r2=1632181view=diff
==
---
qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Connection-URL.html
(original)
+++
qpid/site/docs/releases/qpid-trunk/jms-client-0-8/book/JMS-Client-0-8-Connection-URL.html
Wed Oct 15 21:29:55 2014
@@ -149,15 +149,15 @@
If not specified, the
brokerlist entry for each given broker is used to
determine whether SSL
is used. /p
p Introduced in version 0.22.
/p
-
/td/tr/tbody/table/div/divbr class=table-break /p Broker
lists are specified using a URL in this format: /ppre
class=programlistingbrokerlist=lt;transportgt;://lt;hostgt;[:lt;;portgt;](?lt;paramgt;='lt;valuegt;')(amp;lt;paramgt;='lt;valuegt;')*/prep
For instance, this is a typical broker list: /ppre
class=programlistingbrokerlist='tcp://localhost:5672'/prep A broker list
can contain more than one broker address; if so, the connection is made to
+ /td/trtrtda
id=JMS-Client-0-8-Connection-URL-ConnectionOptions-CompressMessages/acompressMessages/tdtdBoolean/tdtdpControls
whether the client will compress messages before they they are
sent./p/td/trtrtda
id=JMS-Client-0-8-Connection-URL-ConnectionOptions-MessageCompressionThresholdSize/amessageCompressionThresholdSize/tdtdInteger/tdtdpThe
payload size beyond which the client will start to compress message
payloads./p/td/tr/tbody/table/div/divbr class=table-break
/p Broker lists are specified using a URL in this format: /ppre
class=programlistingbrokerlist=lt;transportgt;://lt;hostgt;[:lt;;portgt;](?lt;paramgt;='lt;valuegt;')(amp;lt;paramgt;='lt;valuegt;')*/prep
For instance, this is a typical broker list: /ppre
class=programlistingbrokerlist='tcp://localhost:5672'/prep A broker list
can contain more than one broker address; if so, the connection is made to
the first broker in the list that is available.
- /pdiv class=examplea id=idm233112020384/ap
class=titlestrongExample#160;7.1.#160;Broker Lists/strong/pdiv
class=example-contentspA broker list can specify properties to be used
when connecting to the broker. This
+ /pdiv class=examplea id=idp1948352/ap
class=titlestrongExample#160;7.1.#160;Broker Lists/strong/pdiv
class=example-contentspA broker list can specify properties to be used
when connecting to the broker. This
broker list specifies options for configuring
heartbeating/ppre
class=programlistingamqp://guest:guest@test/test?brokerlist='tcp://ip1:5672?heartbeat='5''/prepThis
broker list specifies some SSL options/ppre
class=programlistingamqp://guest:guest@test/test?brokerlist='tcp://ip1:5672?ssl='true'amp;ssl_cert_alias='cert1''/prep
This broker list specifies two brokers using the connectdelay and retries
broker
options. It also illustrates the failover connection
URL property. /ppre
class=programlistingamqp://guest:guest@/test?failover='roundrobin?cyclecount='2''
amp;brokerlist='tcp://ip1:5672?retries='5'amp;connectdelay='2000';tcp://ip2:5672?retries='5'amp;connectdelay='2000''
/pre/div/divbr class=example-break /div class=important
style=margin-left: 0.5in; margin-right: 0.5in;h3 class=titleBroker
option quoting/h3pTake care with the quoting surrounding broker option
values. Each broker option value
span class=emphasisemmust/em/span be
surrounded with their own single quotes ('). This is in
- addition to the quotes surround the connection option
value./p/divpThe following broker list options are supported./pdiv
class=tablea id=idm233110823984/ap
class=titlestrongTable#160;7.2.#160;Broker List Options/strong/pdiv
class=table-contentstable border=1 summary=Broker List Options
width=100%colgroupcol /col /col //colgrouptheadtrth Option
/thth Type /thth Description /th/tr/theadtbodytrtda
id=JMS-Client-0-8-Connection-URL-BrokerOptions-Heartbeat/a heartbeat
/tdtd Long /tdtd Frequency of heartbeat messages (in seconds). A value
of 0 disables
+ addition to the quotes surround the connection option
value./p/divpThe following broker list options are supported./pdiv
class=tablea id=idp1955648/ap
class=titlestrongTable#160;7.2.#160;Broker List Options/strong/pdiv
class=table-contentstable border=1 summary=Broker List Options
width=100%colgroupcol /col /col //colgrouptheadtrth Option
/thth Type /thth Description /th/tr/theadtbodytrtda
svn commit: r1632181 [6/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Overwrite-Config-Store.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Overwrite-Config-Store.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Overwrite-Config-Store.html (added) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Initial-Configuration-Overwrite-Config-Store.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,146 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +title5.5.#160;Overwriting An Existing Configuration Store - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/lili5.5.#160;Overwriting An Existing Configuration Store/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth
svn commit: r1632181 [8/16] - in /qpid/site: docs/releases/qpid-trunk/ docs/releases/qpid-trunk/java-broker/ docs/releases/qpid-trunk/java-broker/book/ docs/releases/qpid-trunk/java-broker/book/images
Added: qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel.html URL: http://svn.apache.org/viewvc/qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel.html?rev=1632181view=auto == --- qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel.html (added) +++ qpid/site/docs/releases/qpid-trunk/java-broker/book/Java-Broker-Management-Channel.html Wed Oct 15 21:29:55 2014 @@ -0,0 +1,150 @@ +!DOCTYPE html +!-- + - + - 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. + - +-- +html xmlns=http://www.w3.org/1999/xhtml; xml:lang=en + head +titleChapter#160;6.#160;Management Channels - Apache Qpid#8482;/title +meta http-equiv=X-UA-Compatible content=IE=edge/ +meta name=viewport content=width=device-width, initial-scale=1.0/ +link rel=stylesheet href=/site.css type=text/css async=async/ +link rel=stylesheet href=/deferred.css type=text/css defer=defer/ +script type=text/javascriptvar _deferredFunctions = [];/script +script type=text/javascript src=/deferred.js defer=defer/script +!--[if lte IE 8] + link rel=stylesheet href=/ie.css type=text/css/ + script type=text/javascript src=/html5shiv.js/script +![endif]-- + /head + body +div id=-content + div id=-top class=panel +a id=-menu-linkimg width=16 height=16 src=data:image/png;base64, alt=Menu//a + +a id=-search-linkimg width=22 height=16 src=data:image/png;base64, alt=Search//a + +ul id=-global-navigation + lia id=-logotype href=/index.htmlApache Qpidsup#8482;/sup/a/li + lia href=/download.htmlDownload/a/li + lia href=/documentation.htmlDocumentation/a/li + lia href=/discussion.htmlDiscussion/a/li + lia href=/issues.htmlIssues/a/li + lia href=/source-code.htmlSource Code/a/li + lia href=/resources.htmlMore Resources/a/li +/ul + /div + + div id=-menu class=panel style=display: none; +section + h3Project/h3 + + ul +lia href=/overview.htmlOverview/a/li +lia href=/proton/index.htmlQpid Proton/a/li +lia href=/contributors.htmlContributors/a/li +lia href=/get-involved.htmlGet involved/a/li + /ul +/section + +section + h3Software/h3 + + ul +lia href=/download.htmlDownload/a/li +lia href=/documentation.htmlDocumentation/a/li +lia href=/components/index.htmlComponents/a/li +lia href=/releases/index.htmlReleases/a/li + /ul +/section + +section + h3Resources/h3 + + ul +lia href=/discussion.htmlDiscussion/a/li +lia href=/issues.htmlIssues/a/li +lia href=/source-code.htmlSource code/a/li +lia href=/resources.htmlMore resources/a/li + /ul +/section + +section + h3More/h3 + + ul +lia href=/amqp.htmlAMQP/a/li +lia href=/developer.htmlDeveloper central/a/li +lia href=https://cwiki.apache.org/confluence/display/qpid/;Wiki/a/li + /ul +/section + /div + + div id=-search class=panel style=display: none; +form action=http://www.google.com/search; method=get + input type=hidden name=sitesearch value=qpid.apache.org/ + input type=text name=q maxlength=255 autofocus=autofocus tabindex=1/ + button type=submitSearch/button + pa href=/search.htmlMore ways to search/a/p +/form + /div + + div id=-middle class=panel +ul id=-path-navigationlia href=/releases/index.htmlReleases/a/lilia href=/releases/qpid-trunk/index.htmlQpid Trunk/a/lilia href=/releases/qpid-trunk/java-broker/book/index.htmlAMQP Messaging Broker (Java)/a/liliChapter#160;6.#160;Management Channels/li/ul +div class=docbookdiv class=navheadertable summary=Navigation header width=100%trth align=center colspan=3Chapter#160;6.#160;Management Channels/th/trtrtd align=left width=20%a accesskey=p
git commit: Add the ability for adding in a custom intercepter to manage conversion of foreign destination types that we don't know how to convert ourselves. Default implementation will look for isTop
Repository: qpid-jms
Updated Branches:
refs/heads/master 6a221b168 - 3fc2d8b1a
Add the ability for adding in a custom intercepter to manage conversion
of foreign destination types that we don't know how to convert
ourselves. Default implementation will look for isTopic or isQueue
method in the class before giving up. Add some tests around this.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/3fc2d8b1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/3fc2d8b1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/3fc2d8b1
Branch: refs/heads/master
Commit: 3fc2d8b1a1e879a092a881f083cd33b256dff7ac
Parents: 6a221b1
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 18:28:07 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 18:28:07 2014 -0400
--
...DefaultUnresolvedDestinationTransformer.java | 77
.../jms/message/JmsMessageTransformation.java | 25 +--
.../JmsUnresolvedDestinationTransformer.java| 56 ++
.../message/JmsMessageTransformationTest.java | 41 +++
4 files changed, 194 insertions(+), 5 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/3fc2d8b1/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
--
diff --git
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
new file mode 100644
index 000..1d90cd0
--- /dev/null
+++
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
@@ -0,0 +1,77 @@
+/**
+ * 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.message;
+
+import java.lang.reflect.Method;
+
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.Queue;
+import javax.jms.Topic;
+
+import org.apache.qpid.jms.JmsDestination;
+import org.apache.qpid.jms.JmsQueue;
+import org.apache.qpid.jms.JmsTopic;
+
+/**
+ * Default Destination resolver that will try and find a way to convert an
unknown foreign
+ * JMS Destination object by looking for method in the object to identify the
true type.
+ *
+ * For a String destination this class will always return a Queue.
+ */
+public class JmsDefaultUnresolvedDestinationTransformer implements
JmsUnresolvedDestinationTransformer {
+
+@Override
+public JmsDestination transform(Destination destination) throws
JMSException {
+
+String queueName = null;
+String topicName = null;
+
+if (destination instanceof Queue) {
+queueName = ((Queue) destination).getQueueName();
+}
+
+if (destination instanceof Topic) {
+topicName = ((Topic) destination).getTopicName();
+}
+
+if (queueName == null topicName == null) {
+throw new JMSException(Unresolvable destination: Both queue and
topic names are null: + destination);
+}
+
+try {
+Method isQueueMethod = destination.getClass().getMethod(isQueue);
+Method isTopicMethod = destination.getClass().getMethod(isTopic);
+Boolean isQueue = (Boolean) isQueueMethod.invoke(destination);
+Boolean isTopic = (Boolean) isTopicMethod.invoke(destination);
+if (isQueue) {
+return new JmsQueue(queueName);
+} else if (isTopic) {
+return new JmsTopic(topicName);
+} else {
+throw new JMSException(Unresolvable destination: Neither
Queue nor Topic: + destination);
+}
+} catch (Exception e) {
+throw new JMSException(Unresolvable destination: +
e.getMessage() + : + destination);
+}
+}
+
+@Override
+public JmsDestination transform(String destination) throws JMSException {
+
git commit: Throw JMSException is the destinatio name is null.
Repository: qpid-jms
Updated Branches:
refs/heads/master 3fc2d8b1a - bec6b5cec
Throw JMSException is the destinatio name is null.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/bec6b5ce
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/bec6b5ce
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/bec6b5ce
Branch: refs/heads/master
Commit: bec6b5cec175dcdcd9a478dbb074bc202d7274fe
Parents: 3fc2d8b
Author: Timothy Bish tabish...@gmail.com
Authored: Wed Oct 15 18:45:09 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Wed Oct 15 18:45:09 2014 -0400
--
.../jms/message/JmsDefaultUnresolvedDestinationTransformer.java | 4
1 file changed, 4 insertions(+)
--
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/bec6b5ce/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
--
diff --git
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
index 1d90cd0..1193686 100644
---
a/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
+++
b/qpid-jms-client/src/main/java/org/apache/qpid/jms/message/JmsDefaultUnresolvedDestinationTransformer.java
@@ -72,6 +72,10 @@ public class JmsDefaultUnresolvedDestinationTransformer
implements JmsUnresolved
@Override
public JmsDestination transform(String destination) throws JMSException {
+if (destination == null) {
+throw new JMSException(Destination objects cannot have a null
name value);
+}
+
return new JmsQueue(destination);
}
}
-
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
