[typica] r339 committed - support for new SQS attrs, and larger message size

1 view
Skip to first unread message

typ...@googlecode.com

unread,
Jul 9, 2010, 4:04:49 PM7/9/10
to typic...@googlegroups.com
Revision: 339
Author: dkavanagh
Date: Fri Jul 9 13:02:40 2010
Log: support for new SQS attrs, and larger message size

http://code.google.com/p/typica/source/detail?r=339

Modified:
/trunk/java/com/xerox/amazonws/sqs2/MessageQueue.java
/trunk/java/com/xerox/amazonws/sqs2/QueueAttribute.java

=======================================
--- /trunk/java/com/xerox/amazonws/sqs2/MessageQueue.java Thu Jul 8
14:02:57 2010
+++ /trunk/java/com/xerox/amazonws/sqs2/MessageQueue.java Fri Jul 9
13:02:40 2010
@@ -65,7 +65,6 @@
*/
public class MessageQueue extends AWSQueryConnection {
public static final int MAX_MESSAGES = 600;
- public static final int MAX_MESSAGE_BODY_SIZE = 8192;

protected String queueId;
private boolean enableEncoding = true;
@@ -127,9 +126,6 @@
public String sendMessage(String msg) throws SQSException {
Map<String, String> params = new HashMap<String, String>();
String encodedMsg = enableEncoding?new
String(Base64.encodeBase64(msg.getBytes())):msg;
- if (encodedMsg.length() > MAX_MESSAGE_BODY_SIZE) {
- throw new SQSException("Message is to large
(encoding:"+enableEncoding+")");
- }
params.put("MessageBody", encodedMsg);
HttpPost method = new HttpPost();
SendMessageResponse response =
=======================================
--- /trunk/java/com/xerox/amazonws/sqs2/QueueAttribute.java Mon Oct 12
17:10:09 2009
+++ /trunk/java/com/xerox/amazonws/sqs2/QueueAttribute.java Fri Jul 9
13:02:40 2010
@@ -25,6 +25,8 @@
LAST_MODIFIED_TIMESTAMP ("LastModifiedTimestamp"),
VISIBILITY_TIMEOUT ("VisibilityTimeout"),
REQUEST_PAYER ("RequestPayer"),
+ MAXIUMUM_MESSAGE_SIZE ("MaximumMessageSize"),
+ MESSAGE_RETENTION_PERIOD ("MessageRetentionPeriod"),
POLICY ("POLICY");

private final String queryAttribute;

Reply all
Reply to author
Forward
0 new messages