Permalink
Browse files

saving changes.

  • Loading branch information...
1 parent 4a06106 commit dc9ce4aec42a2462058392f8b521d3326aa826ff Neil committed Jul 29, 2009
@@ -74,7 +74,15 @@
<outbound-endpoint ref="GroupsWS"/>
<payload-type-filter expectedType="edu.ucsb.eucalyptus.msgs.VmSecurityMessage"/>
</filtering-router>
- </outbound>
+ <filtering-router>
+ <outbound-endpoint ref="BukkitWS"/>
+ <payload-type-filter expectedType="edu.ucsb.eucalyptus.msgs.WalrusRequestType"/>
+ </filtering-router>
+ <filtering-router>
+ <outbound-endpoint ref="StorageWS"/>
+ <payload-type-filter expectedType="edu.ucsb.eucalyptus.msgs.StorageRequestType"/>
+ </filtering-router>
+ </outbound>
</service>
<service name="ReplyQueue">
@@ -85,4 +93,4 @@
</service>
</model>
-</mule>
+</mule>
@@ -51,7 +51,7 @@
<inbound>
<inbound-endpoint ref="WalrusReplyQueueWS"/>
</inbound>
- <component class="edu.ucsb.eucalyptus.ic.WalrusReplyQueue"/>
+ <component class="com.eucalyptus.ws.util.ReplyQueue"/>
</service>
</model>
Oops, something went wrong.
@@ -55,6 +55,7 @@
import java.util.Date;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
+import com.eucalyptus.ws.handlers.WalrusRESTBinding;
public class WalrusManager {
private static Logger LOG = Logger.getLogger( WalrusManager.class );
@@ -445,7 +446,7 @@ public PutObjectResponseType putObject(PutObjectType request) throws EucalyptusC
//writes are unconditional
String randomKey = request.getRandomKey();
- WalrusDataMessenger messenger = null;// TODO: NEIL WalrusQueryDispatcher.getWriteMessenger();
+ WalrusDataMessenger messenger = WalrusRESTBinding.getWriteMessenger();
String key = bucketName + "." + objectKey;
LinkedBlockingQueue<WalrusDataMessage> putQueue = messenger.getQueue(key, randomKey);
Oops, something went wrong.

0 comments on commit dc9ce4a

Please sign in to comment.