Issue #427 minor fix

Change-Id: I341e046bcde321ae70a2afeb745bedb0078758ca

Former-commit-id: 2d544b5c2fb48870173ea9d38b4c7370f6ebe49f
This commit is contained in:
Nate Jensen 2012-04-24 15:28:36 -05:00
parent c4afe61f01
commit fd1f337a92
5 changed files with 13 additions and 30 deletions

View file

@ -160,8 +160,9 @@ public class CollaborationDataManager implements IRosterEventSubscriber {
usersMap.put(rosterEntry.getUser(), rosterEntry); usersMap.put(rosterEntry.getUser(), rosterEntry);
} }
usersMap.put(connection.getUser(), RosterEntry me = new RosterEntry(connection.getUser());
new RosterEntry(connection.getUser())); me.setPresence(connection.getPresence());
usersMap.put(me.getUser(), me);
} }
/** /**

View file

@ -39,7 +39,7 @@
package com.raytheon.uf.viz.collaboration.comm.identity; package com.raytheon.uf.viz.collaboration.comm.identity;
import com.raytheon.uf.viz.collaboration.comm.identity.event.IEventPublisher; import com.raytheon.uf.viz.collaboration.comm.identity.event.IEventPublisher;
import com.raytheon.uf.viz.collaboration.comm.identity.user.IQualifiedID; import com.raytheon.uf.viz.collaboration.comm.provider.user.UserId;
/** /**
* TODO Add Description * TODO Add Description
@ -75,7 +75,7 @@ public interface ISession extends IEventPublisher {
* *
* @return * @return
*/ */
public IQualifiedID getUserID(); public UserId getUserID();
/** /**
* Gets the connection status of the session. * Gets the connection status of the session.

View file

@ -34,7 +34,7 @@ import org.eclipse.ecf.presence.IPresenceContainerAdapter;
import com.google.common.eventbus.EventBus; import com.google.common.eventbus.EventBus;
import com.raytheon.uf.viz.collaboration.comm.identity.CollaborationException; import com.raytheon.uf.viz.collaboration.comm.identity.CollaborationException;
import com.raytheon.uf.viz.collaboration.comm.identity.ISession; import com.raytheon.uf.viz.collaboration.comm.identity.ISession;
import com.raytheon.uf.viz.collaboration.comm.identity.user.IQualifiedID; import com.raytheon.uf.viz.collaboration.comm.provider.user.UserId;
/** /**
* TODO Add Description * TODO Add Description
@ -69,7 +69,7 @@ public abstract class BaseSession implements ISession {
private Namespace connectionNamespace = null; private Namespace connectionNamespace = null;
// The session manager that created this session. // The session manager that created this session.
private CollaborationConnection sessionManager; private CollaborationConnection connection;
/** /**
* *
@ -97,7 +97,7 @@ public abstract class BaseSession implements ISession {
managerEventBus = externalBus; managerEventBus = externalBus;
eventBus = new EventBus(); eventBus = new EventBus();
connectionContainer = container; connectionContainer = container;
sessionManager = manager; connection = manager;
eventSubscribers = new HashMap<Object, Object>(); eventSubscribers = new HashMap<Object, Object>();
setup(); setup();
} }
@ -122,7 +122,7 @@ public abstract class BaseSession implements ISession {
* @throws CollaborationException * @throws CollaborationException
*/ */
PeerToPeerChat getP2PSession() throws CollaborationException { PeerToPeerChat getP2PSession() throws CollaborationException {
return (PeerToPeerChat) sessionManager.getPeerToPeerSession(); return (PeerToPeerChat) connection.getPeerToPeerSession();
} }
/** /**
@ -162,7 +162,7 @@ public abstract class BaseSession implements ISession {
* @return * @return
*/ */
CollaborationConnection getSessionManager() { CollaborationConnection getSessionManager() {
return sessionManager; return connection;
} }
/** /**
@ -186,8 +186,8 @@ public abstract class BaseSession implements ISession {
* @see com.raytheon.uf.viz.collaboration.comm.identity.ISession#getUserID() * @see com.raytheon.uf.viz.collaboration.comm.identity.ISession#getUserID()
*/ */
@Override @Override
public IQualifiedID getUserID() { public UserId getUserID() {
return null; return connection.getUser();
} }
/** /**
@ -213,7 +213,7 @@ public abstract class BaseSession implements ISession {
// for(Object o : eventSubscribers.values()) { // for(Object o : eventSubscribers.values()) {
// managerEventBus.unregister(o); // managerEventBus.unregister(o);
// } // }
sessionManager.removeSession(this); connection.removeSession(this);
} }
/** /**

View file

@ -399,7 +399,6 @@ public class CollaborationConnection implements IEventPublisher {
if (session != null) { if (session != null) {
session.joinVenue(venueName); session.joinVenue(venueName);
session.setUserId(account);
if (invitation.getInvite() instanceof SharedDisplayVenueInvite) { if (invitation.getInvite() instanceof SharedDisplayVenueInvite) {
SharedDisplayVenueInvite invite = (SharedDisplayVenueInvite) invitation SharedDisplayVenueInvite invite = (SharedDisplayVenueInvite) invitation
.getInvite(); .getInvite();
@ -431,7 +430,6 @@ public class CollaborationConnection implements IEventPublisher {
session.createVenue(venueName, subject); session.createVenue(venueName, subject);
session.setCurrentSessionLeader(account); session.setCurrentSessionLeader(account);
session.setCurrentDataProvider(account); session.setCurrentDataProvider(account);
session.setUserId(account);
sessions.put(session.getSessionId(), session); sessions.put(session.getSessionId(), session);
return session; return session;

View file

@ -115,8 +115,6 @@ public class VenueSession extends BaseSession implements IVenueSession {
private IChatRoomParticipantListener participantListener = null; private IChatRoomParticipantListener participantListener = null;
private IQualifiedID userID = null;
private String subject; private String subject;
/** /**
@ -140,16 +138,6 @@ public class VenueSession extends BaseSession implements IVenueSession {
super(container, externalBus, manager); super(container, externalBus, manager);
} }
/**
* Get the identification of the owner of this session.
*
* @see com.raytheon.uf.viz.collaboration.comm.identity.ISession#getUserID()
*/
@Override
public IQualifiedID getUserID() {
return userID;
}
/** /**
* Close this session. Closing clears all listeners and disposes of the * Close this session. Closing clears all listeners and disposes of the
* container. No errors for attempting to close an already closed session. * container. No errors for attempting to close an already closed session.
@ -301,10 +289,6 @@ public class VenueSession extends BaseSession implements IVenueSession {
} }
} }
protected void setUserId(UserId id) {
this.userID = id;
}
protected void joinVenue(String venueName) throws CollaborationException { protected void joinVenue(String venueName) throws CollaborationException {
try { try {
// Create chat room container from manager // Create chat room container from manager