In my application when user [A] initiate the chat with user[B] , I am facing following issues
- User[B] is not getting initiation notification so that I am unable to open chat pod for user [A] on user[B] application
- Due to above problem , User[B] not getting any message sent by the User[A]
- User[A] can send only one message and it is displayed on simple chat pod
when User[A]tries to send more then one message it is not displayed on simple chat pod but on the console I can see the messages
following is sample code
public function connectChat() :void
{
_collectionNode =
new CollectionNode();
_collectionNode.sharedID = NOTIFICATION_COLLECTION_NODE;
_collectionNode.connectSession =
this.connectSession;
_collectionNode.addEventListener(CollectionNodeEvent.SYNCHRONIZATION_CHANGE, onSynchronizationChange,
false, 0, true);
_collectionNode.addEventListener(CollectionNodeEvent.ITEM_RECEIVE, onItemReceive,
false, 0, true);
_collectionNode.subscribe();
}
/**
* @private
* Handles the creation of a collection node if it does not already exist
*/
protected function onSynchronizationChange(event:CollectionNodeEvent):void {
if (_collectionNode.isSynchronized) {
if (!_collectionNode.isNodeDefined(START_CHAT_LIST) && _collectionNode.canUserConfigure(connectSession.userManager.myUserID)) {
_collectionNode.createNode(START_CHAT_LIST,
new NodeConfiguration(UserRoles.VIEWER, UserRoles.VIEWER, true, false, true,false, NodeConfiguration.STORAGE_SCHEME_QUEUE));
}
}
}
public function connectChat() :void
{
trace('connectChat');
_collectionNode =
new CollectionNode();
_collectionNode.sharedID = NOTIFICATION_COLLECTION_NODE;
_collectionNode.connectSession =
this.connectSession;
_collectionNode.addEventListener(CollectionNodeEvent.SYNCHRONIZATION_CHANGE, onSynchronizationChange,
false, 0, true);
_collectionNode.addEventListener(CollectionNodeEvent.ITEM_RECEIVE, onItemReceive,
false, 0, true);
_collectionNode.subscribe();
}
/**
* @private
* Handles the creation of a collection node if it does not already exist
*/
protected function onSynchronizationChange(event:CollectionNodeEvent):void {
if (_collectionNode.isSynchronized) {
//Creates the nodes if they don't exist
if (!_collectionNode.isNodeDefined(START_CHAT_LIST) && _collectionNode.canUserConfigure(connectSession.userManager.myUserID)) {
_collectionNode.createNode(START_CHAT_LIST,
new NodeConfiguration(UserRoles.VIEWER, UserRoles.VIEWER, true, false, true,false, NodeConfiguration.STORAGE_SCHEME_QUEUE));
}
}
}
/**
* Checks if a chat is going to be started with this specific user
*/
protected function onItemReceive(event:CollectionNodeEvent):void {
var item:MessageItem = event.item;
var openChatEvent:OpenChatEvent = OpenChatEvent.ToOpenChatEvent( item.body, OpenChatEvent.OPEN_CHAT );
switch (item.nodeName) {
case START_CHAT_LIST:
trace("Starting Chat Notified");
if( openChatEvent.userId && openChatEvent.userId == this.connectSession.userManager.myUserID )
{
this.dispatchEvent( openChatEvent );
if( this._collectionNode.isSynchronized )
this._collectionNode.retractItem( START_CHAT_LIST, openChatEvent.roomId );
}
break;
}
}
/**
* Publishes a request for someone to join a chat
*/
public function publishChatRequest(notificationEvent : NotificationEvent) :void {
if( this.connectSession.userManager.getUserDescriptor( notificationEvent.userID ) )
{
var openChatEvent:OpenChatEvent = new OpenChatEvent( OpenChatEvent.PUBLISH_CHAT,null,notificationEvent.sharedID, notificationEvent.userNotificationList, null, notificationEvent.userID );
if( this.presenceUsers )
openChatEvent.descriptors =
this.presenceUsers;
_collectionNode.publishItem(
new MessageItem( START_CHAT_LIST, openChatEvent, openChatEvent.roomId ) );
}
else
{
Alert.show(
"User "+ notificationEvent.userID + " is not logged in.", "Publish Error" );
}
}
}
