Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-5402 

Revert the changes here as the mapping is moving in a different
direction.

4881a848dc
This commit is contained in:
Timothy Bish 2014-10-29 14:16:34 -04:00
parent dffccb1c7d
commit 0b148ade32
2 changed files with 0 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
View File

@ -134,7 +134,6 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
protected Transport protonTransport = Proton.transport(); protected Transport protonTransport = Proton.transport();
protected Connection protonConnection = Proton.connection(); protected Connection protonConnection = Proton.connection();
protected Collector eventCollector = new CollectorImpl(); protected Collector eventCollector = new CollectorImpl();
protected boolean useByteDestinationTypeAnnotation;
public AmqpProtocolConverter(AmqpTransport transport, BrokerService brokerService) { public AmqpProtocolConverter(AmqpTransport transport, BrokerService brokerService) {
this.amqpTransport = transport; this.amqpTransport = transport;
@ -146,8 +145,6 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
this.protonTransport.setMaxFrameSize(maxFrameSize); this.protonTransport.setMaxFrameSize(maxFrameSize);
} }
useByteDestinationTypeAnnotation = transport.getWireFormat().isUseByteDestinationTypeAnnotation();
this.protonTransport.bind(this.protonConnection); this.protonTransport.bind(this.protonConnection);
// NOTE: QPid JMS client has a bug where the channel max is stored as a // NOTE: QPid JMS client has a bug where the channel max is stored as a
@ -488,17 +485,6 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
connectionInfo.setClientId(clientId); connectionInfo.setClientId(clientId);
} }
Map<Symbol, Object> props = protonConnection.getRemoteProperties();
if (props != null) {
if (props.containsKey(JMS_MAPPING_VERSION)) {
useByteDestinationTypeAnnotation = true;
}
}
if (useByteDestinationTypeAnnotation) {
outboundTransformer.setUseByteDestinationTypeAnnotations(true);
}
connectionInfo.setTransportContext(amqpTransport.getPeerCertificates()); connectionInfo.setTransportContext(amqpTransport.getPeerCertificates());
sendToActiveMQ(connectionInfo, new ResponseHandler() { sendToActiveMQ(connectionInfo, new ResponseHandler() {
@ -572,10 +558,6 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
LOG.warn("Unknown transformer type {} using native one instead", transformer); LOG.warn("Unknown transformer type {} using native one instead", transformer);
inboundTransformer = new AMQPNativeInboundTransformer(ActiveMQJMSVendor.INSTANCE); inboundTransformer = new AMQPNativeInboundTransformer(ActiveMQJMSVendor.INSTANCE);
} }
if (useByteDestinationTypeAnnotation) {
inboundTransformer.setUseByteDestinationTypeAnnotations(true);
}
} }
return inboundTransformer; return inboundTransformer;
} }

9
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpWireFormat.java
View File

@ -41,7 +41,6 @@ public class AmqpWireFormat implements WireFormat {
private long maxFrameSize = DEFAULT_MAX_FRAME_SIZE; private long maxFrameSize = DEFAULT_MAX_FRAME_SIZE;
private int maxAmqpFrameSize = NO_AMQP_MAX_FRAME_SIZE; private int maxAmqpFrameSize = NO_AMQP_MAX_FRAME_SIZE;
private String anonymousNodeName = "$relay"; private String anonymousNodeName = "$relay";
private boolean useByteDestinationTypeAnnotation = false;
@Override @Override
public ByteSequence marshal(Object command) throws IOException { public ByteSequence marshal(Object command) throws IOException {
@ -136,12 +135,4 @@ public class AmqpWireFormat implements WireFormat {
public void setAnonymousNodeName(String anonymousNodeName) { public void setAnonymousNodeName(String anonymousNodeName) {
this.anonymousNodeName = anonymousNodeName; this.anonymousNodeName = anonymousNodeName;
} }
public boolean isUseByteDestinationTypeAnnotation() {
return useByteDestinationTypeAnnotation;
}
public void setUseByteDestinationTypeAnnotation(boolean useByteDestinationTypeAnnotation) {
this.useByteDestinationTypeAnnotation = useByteDestinationTypeAnnotation;
}
} }