patelm5

@Test
public void shouldForwardLookupMessageLookupActor(){
	createActorWithPath("lookup-source-"+SOURCE_ID, testProbe);
	ActorRef ref = testProbe.ref();
	lookupActor.tell(new GetContent(SOURCE_ID, SYSTEM_ENTRY_TIME), ref);
	
	LookupResponse actual = testProbe.expectMsgClass(LookupResponse.class);

patelm5

DeserializerFactory withAdditionalDeserializers = BeanDeserializerFactory.instance.withAdditionalDeserializers(setupEnumDeserializer());
DefaultDeserializationContext.Impl dc = new DefaultDeserializationContext.Impl(withAdditionalDeserializers);
ObjectMapper defaultMapper = new ObjectMapper(null, null, dc);


private Deserializers setupEnumDeserializer() {
		Deserializers d = new Deserializers.Base() {
			

	        @Override

patelm5

@Component
@Profile("untrusted")
public class SelfSignedTrustCertConfigurer {

	private final static Logger logger = LoggerFactory.getLogger(SelfSignedTrustCertConfigurer.class.getName());

	@PostConstruct
	public void allowUntrustedCerts() {
		HostnameVerifier hv = new HostnameVerifier() {
			public boolean verify(String urlHostName, SSLSession session) {

patelm5

<plugin>
	<groupId>com.lazerycode.jmeter</groupId>
	<artifactId>jmeter-maven-plugin</artifactId>
	<version>1.9.0</version>
	<executions>
		<execution>
			<id>jmeter-tests</id>
			<phase>verify</phase>
			<goals>

patelm5

function subscriber(){
  
     var socket = $.atmosphere;
     var subSocket;
     var model = [] ;
     
     var obj = {
    		 getModel : function(){ return model ; },
    		 subscribe : function(){ 
    			  var request = { url : document.location.toString()+'atmosphere/?channelId=12351',

patelm5

@Component("broadcastQueueConsumer")
public class BroadcastListener implements MessageListener{

  private final static Logger logger = Logger.getLogger(BroadcastListener.class.getName());
	
	@Autowired
	private SimpleMessageConverter messageAdapter ;
	
	@Autowired
	private BroadcastService broadcastService; 

patelm5

		<dependency>
			<groupId>org.springframework.amqp</groupId>
			<artifactId>spring-rabbit</artifactId>
			<version>1.1.0.RELEASE</version>
		</dependency>

patelm5

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:rabbit="http://www.springframework.org/schema/rabbit" xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.1.xsd
		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

	<rabbit:connection-factory id="connectionFactory" host="${rabbitmq.host:localhost}" port="${rabbitmq.port:5672}"
		username="guest" password="guest" connection-factory="rcf" />
		

patelm5

@Service
public class BroadcastService {

	private final static Logger logger = Logger.getLogger(BroadcastService.class.getName());

	private Map<String, Broadcaster> broadcastTokens = new ConcurrentHashMap<String, Broadcaster>();

	public void broadcast(String message) {
		for (Broadcaster token : broadcastTokens.values()) {
				token.broadcast(message);

patelm5

<!-- Atmosphere -->
<servlet>
		<description>AtmosphereServlet</description>
		<servlet-name>AtmosphereServlet</servlet-name>
		<servlet-class>org.atmosphere.cpr.AtmosphereServlet</servlet-class>


		<init-param>
			<param-name>org.atmosphere.cpr.broadcasterLifeCyclePolicy</param-name>
			<param-value>EMPTY_DESTROY</param-value>