meteor-chat: Send back response message from console client

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

meteor-chat: Send back response message from console client

tokajac
This post has NOT been accepted by the mailing list yet.
Hello,

What's the optimal way to send (back) message from console client?
Rebuilding meteor-chat sample and plan to send message back when receive one LONG_POOLING via method below:
public AsyncHandler.STATE onBodyPartReceived(HttpResponseBodyPart bodyPart) throws Exception

If below commented out POST code is active, it leads to (infinite) circular event invocation.
Aim is to reach proper Broadcaster, as far as I see, but how to reach it from console client?
BroadcasterFactory.getDefault().lookup(DefaultBroadcaster.class, "/*").broadcast(new Data(author, message).toString());

Any idea or clue?

Regards

P.S.
Console client code for picking up messages:

        public static void main(String[] args){

        Builder builder = new AsyncHttpClientConfig.Builder();
        builder.setCompressionEnabled(true).setAllowPoolingConnection(true).build();

        final AsyncHttpClient client = new AsyncHttpClient(builder.build());

        try {
// client.prepareGet("http://127.0.0.1:8080/atmosphere-rest-chat/chat").execute(new AsyncHandler<String>() {
                        client.prepareGet("http://127.0.0.1:8080/atmosphere-meteor-chat/meteor").execute(new AsyncHandler<String>() {
                                public void onThrowable(Throwable t) {
                                        System.out.println("onThrowable");
                                        t.printStackTrace();
                                }

                                public AsyncHandler.STATE onBodyPartReceived(HttpResponseBodyPart bodyPart) throws Exception {
                                        System.out.println("onBodyPartReceived");
                                        System.out.println(new String(bodyPart.getBodyPartBytes()));
                                       
//console client authentication
                                       
                                        String bodyData = "{ \"text\" : \"MessageToSend\", \"author\" : \"Meteor\" , \"time\" : 1360086038178}";                
/*                
                    client.preparePost("http://localhost:8080/atmosphere-meteor-chat/meteor").
                    addParameter("action", "login").
                    addParameter("name", "testJava").setHeader("Content-Type", "application/json; charset=utf-8").setBodyEncoding("UTF-8").setBody(bodyData).execute();
                    System.out.println("console authentication completed");
*/                        
                                       
                                        System.out.println("URL: "+bodyPart.getUrl());
                                        return AsyncHandler.STATE.CONTINUE;
                                }

                                public AsyncHandler.STATE onStatusReceived(HttpResponseStatus responseStatus) throws Exception {
                                        System.out.println("onStatusReceived");
                                        return AsyncHandler.STATE.CONTINUE;
                                }

                                public AsyncHandler.STATE onHeadersReceived(HttpResponseHeaders headers) throws Exception {
                                        System.out.println("onHeadersReceived");
                                        return AsyncHandler.STATE.CONTINUE;
                                }

                                public String onCompleted() throws Exception {
                                        System.out.println("onCompleted");
                                        return "";
                                }
                        });
                } catch (IOException e1) {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                }
   
       
            new Timer().schedule(new TimerTask() {
                    @Override
                    public void run() {
                            try {
                            client.preparePost("http://127.0.0.1:8080/atmosphere-meteor-chat/meteor").
                                    addParameter("action", "login").
                                    addParameter("name", "testJava").execute();
                                   
                            } catch (Exception e) {
                                    System.err.println("Se pudrio todo");
                                    e.printStackTrace();
                            }
                    }
            }, 5000);
           
           
            new Timer().schedule(new TimerTask() {
                @Override
                public void run() {
                        try {
                            client.preparePost("http://127.0.0.1:8080/atmosphere-meteor-chat/meteor")
                                .addParameter("action", "post").
                                addParameter("name", "testJava").
                                addParameter("message", "test msg from java test").execute();
                        } catch (Exception e) {
                                System.err.println("Se pudrio todo");
                                e.printStackTrace();
                        }
                }
        }, 15000);    
        }
Loading...