Skip to content

Instantly share code, notes, and snippets.

package com.cyant.chat.protocol;
import com.cyant.chat.CustomerEvents;
import com.cyant.chat.events.customer.InitiateEvent;
import com.cyant.chat.modal.CustomerUser;
import com.cyant.chat.modal.Organisation;
import com.cyant.chat.protocol.listener.CustomerActivity;
import com.cyant.chat.service.OrganisationService;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
package com.cyant.chat;
import com.cyant.chat.api.Client;
import com.cyant.chat.protocol.CustomerProtocol;
import com.cyant.chat.protocol.OperatorProtocol;
import com.cyant.chat.service.OrganisationService;
import com.google.inject.AbstractModule;
import com.google.inject.Guice;
import com.google.inject.Injector;
import org.atmosphere.nettosphere.Handler;
package com.cyant.chat.protocol;
import com.cyant.chat.CustomerEvents;
import com.cyant.chat.events.customer.InitiateEvent;
import com.cyant.chat.modal.CustomerUser;
import com.cyant.chat.modal.Organisation;
import com.cyant.chat.protocol.listener.CustomerActivity;
import com.cyant.chat.service.OrganisationService;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
package com.cyant.chat.protocol.listener;
import com.cyant.chat.modal.Customer;
import com.cyant.chat.modal.customer.Activity;
import com.fasterxml.jackson.databind.JsonNode;
import org.atmosphere.cpr.AtmosphereRequest;
import org.atmosphere.cpr.AtmosphereResource;
import org.atmosphere.cpr.AtmosphereResourceEvent;
import org.atmosphere.cpr.AtmosphereResourceEventListenerAdapter;
import org.slf4j.Logger;
package com.cyant.chat.protocol;
import com.cyant.chat.Organisation;
import com.cyant.chat.event.ErrorEvent;
import com.cyant.chat.user.CustomerUser;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.fge.jackson.JsonLoader;
import org.atmosphere.cache.UUIDBroadcasterCache;
import org.atmosphere.client.TrackMessageSizeInterceptor;
package com.cyant.chat.protocol;
import com.cyant.chat.Organisation;
import com.cyant.chat.event.ErrorEvent;
import com.cyant.chat.user.OperatorUser;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.fge.jackson.JsonLoader;
import org.atmosphere.cache.UUIDBroadcasterCache;
import org.atmosphere.client.TrackMessageSizeInterceptor;
package com.cyant.chat;
import com.cyant.chat.event.operator.AddCustomerEvent;
import com.cyant.chat.user.CustomerUser;
import com.cyant.chat.user.OperatorUser;
import org.atmosphere.cpr.*;
import java.util.ArrayList;
import java.util.Collection;
package com.cyant.chat.protocol;
import com.cyant.chat.Organisation;
import com.cyant.chat.event.ErrorEvent;
import com.cyant.chat.user.OperatorUser;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.fge.jackson.JsonLoader;
import org.atmosphere.cache.UUIDBroadcasterCache;
import org.atmosphere.client.TrackMessageSizeInterceptor;
package com.cyant.chat.modal;
public class OperatorUser extends AbstractUser
{
protected String avatar;
protected String displayName;
public OperatorUser(String displayName, String avatar)
{
package com.cyant.chat.protocol;
import com.cyant.chat.Organisation;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.fge.jackson.JsonLoader;
import org.atmosphere.cache.UUIDBroadcasterCache;
import org.atmosphere.client.TrackMessageSizeInterceptor;
import org.atmosphere.config.service.AtmosphereHandlerService;