I can publish message successfully using API for Android , but when I want to receive the messages using my subscribe method it doesn’t work
THIS IS MY PUBLISHING METHOD
public class Test extends AppCompatActivity
{
ImageView send_comment;
@Override
protected void onCreate(Bundle savedInstanceState)
{send_comment.setOnClickListener(new View.OnClickListener()
{
@Override
public void onClick(View v)
{
//PUBLISH MESSAGE
PublishOptions publishOptions=new PublishOptions();
publishOptions.putHeader(“category”,nombre_categoria);
publishOptions.putHeader(“question_id”,id_pregunta);
Backendless.Messaging.publish(“default”,“comment”,publishOptions,new AsyncCallback<MessageStatus>()
{
@Override
public void handleResponse(MessageStatus response)
{
System.out.println(“MESSAGE SUCCESSFUL PUBLISH:”+ “comment”);
}
@Override
public void handleFault(BackendlessFault fault)
{
showToast(“ERROR PUBLISH:”+" " + fault.getMessage());
}
});//END BACKENDLESS.MESSAGING.PUBLISH
}//END PUBLIC VOID
});//END CLICK IMAGEVIEW
}//END ONCREATE
}//END CLASS<----------END PUBLISHING CODE------------>
THIS IS THE SUSBCRIBER
public class Test extends AppCompatActivity
{
ImageView send_comment;
@Override
protected void onCreate(Bundle savedInstanceState)
{send_comment.setOnClickListener(new View.OnClickListener()
{
@Override
public void onClick(View v)
{
//IF I CALL SUBSCRIBE METHOD FROM HERE, IT WORKS PROPERLY
}//END PUBLIC VOID
});//END CLICK IMAGEVIEW
subscribe(); //IF I CALL SUBSCRIBE FROM HERE, IT DOESN’T NO WORK
//IT SHOULD BE CALLED WHEN ACTIVITY LOADS
//END ONCREATE
public void subscribe()
{
AsyncCallback<List<Message>> subscriptionResponder = new AsyncCallback<List<Message>>()
{
public void handleResponse(List<Message> messages)
{
for(Message message:messages)
{
System.out.println(“MESSAGE RECEIVED:”+message.getData())
}
}
public void handleFault( BackendlessFault fault )
{
showToast(“ERROR ASYNCCALLBACK METODO subscriptionResponder:”+" " + fault.getMessage());
}
};
//SUBSCRIBE MESSAGE
SubscriptionOptions subscriptionOptions=new SubscriptionOptions();
String selector=“category=’”+nombre_categoria+"’ and question_id=’"+id_pregunta+"’";
subscriptionOptions.setSelector(selector);
Backendless.Messaging.subscribe(“default”,subscriptionResponder,subscriptionOptions,new AsyncCallback<Subscription>()
{
@Override
public void handleResponse(Subscription response)
{
showToast(“SUCCESSFULL SUBSCRIBE:”+" “+ response.getSubscriptionId());
}
@Override
public void handleFault(BackendlessFault fault)
{
showToast(“ERROR MESSAGE SUBSCRBING :”+” " + fault.getMessage());
}
});
}
}//END CLASS