removed dependency on class defined in the test branch of spring-amqp-core from spring-rabbit test code

This commit is contained in:
Mark Fisher
2010-07-02 17:47:15 -04:00
parent 452d6bf44a
commit e178bdb6ee

View File

@@ -1,12 +1,15 @@
package org.springframework.amqp.rabbit.core;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import org.springframework.amqp.core.Address;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageCreator;
import org.springframework.amqp.core.MessageDeliveryMode;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.core.TestMessageProperties;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
//import org.springframework.otp.erlang.connection.ConnectionParameters;
public class Producer {
@@ -46,4 +49,219 @@ public class Producer {
System.out.println("sending " + i + "...");
}
}
@SuppressWarnings("unused")
private static class TestMessageProperties implements MessageProperties {
private volatile String appId;
private volatile String clusterId;
private volatile String contentEncoding;
private volatile long contentLength;
private volatile String contentType = MessageProperties.CONTENT_TYPE_BYTES;
private volatile byte[] correlationId;
private volatile MessageDeliveryMode deliveryMode = MessageDeliveryMode.PERSISTENT;
private volatile long deliveryTag;
private volatile String expiration;
private volatile Map<String, Object> headers = new HashMap<String, Object>();
private volatile Integer messageCount;
private volatile String messageId;
private volatile Integer priority;
private volatile String receivedExchange;
private volatile String receivedRoutingKey;
private volatile Address replyTo;
private volatile Date timestamp;
private volatile String type;
private volatile String userId;
private volatile Boolean redelivered;
public String getAppId() {
return this.appId;
}
public void setAppId(String appId) {
this.appId = appId;
}
public String getClusterId() {
return this.clusterId;
}
public void setClusterId(String clusterId) {
this.clusterId = clusterId;
}
public String getContentEncoding() {
return this.contentEncoding;
}
public void setContentEncoding(String contentEncoding) {
this.contentEncoding = contentEncoding;
}
public long getContentLength() {
return this.contentLength;
}
public void setContentLength(long contentLength) {
this.contentLength = contentLength;
}
public String getContentType() {
return this.contentType;
}
public void setContentType(String contentType) {
this.contentType = contentType;
}
public byte[] getCorrelationId() {
return this.correlationId;
}
public void setCorrelationId(byte[] correlationId) {
this.correlationId = correlationId;
}
public MessageDeliveryMode getDeliveryMode() {
return this.deliveryMode;
}
public void setDeliveryMode(MessageDeliveryMode deliveryMode) {
this.deliveryMode = deliveryMode;
}
public long getDeliveryTag() {
return this.deliveryTag;
}
public void setDeliveryTag(long deliveryTag) {
this.deliveryTag = deliveryTag;
}
public String getExpiration() {
return this.expiration;
}
public void setExpiration(String expiration) {
this.expiration = expiration;
}
public Map<String, Object> getHeaders() {
return this.headers;
}
public void setHeaders(Map<String, Object> headers) {
this.headers = headers;
}
public Integer getMessageCount() {
return this.messageCount;
}
public void setMessageCount(Integer messageCount) {
this.messageCount = messageCount;
}
public String getMessageId() {
return this.messageId;
}
public void setMessageId(String messageId) {
this.messageId = messageId;
}
public Integer getPriority() {
return this.priority;
}
public void setPriority(Integer priority) {
this.priority = priority;
}
public String getReceivedExchange() {
return this.receivedExchange;
}
public void setReceivedExchange(String receivedExchange) {
this.receivedExchange = receivedExchange;
}
public String getReceivedRoutingKey() {
return this.receivedRoutingKey;
}
public void setReceivedRoutingKey(String receivedRoutingKey) {
this.receivedRoutingKey = receivedRoutingKey;
}
public Address getReplyTo() {
return this.replyTo;
}
public void setReplyTo(Address replyTo) {
this.replyTo = replyTo;
}
public Date getTimestamp() {
return this.timestamp;
}
public void setTimestamp(Date timestamp) {
this.timestamp = timestamp;
}
public String getType() {
return this.type;
}
public void setType(String type) {
this.type = type;
}
public String getUserId() {
return this.userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public Boolean isRedelivered() {
return this.redelivered;
}
public void setRedelivered(Boolean redelivered) {
this.redelivered = redelivered;
}
public void setHeader(String key, Object value) {
this.headers.put(key, value);
}
public void setDefaultCharset(String charSet) {
// TODO: where would this be used?
}
}
}