@Override
public String call() throws Exception {
TopicService service = getService();
ClientEndpoint endpoint = getEndpoint();
MessageListener listener = new MessageListenerImpl(endpoint, getCallId());
String registrationId = service.addMessageListener(name, listener);
endpoint.setListenerRegistration(TopicService.SERVICE_NAME, name, registrationId);
return registrationId;
}
@Override