Kundan Ray Akela (Manager-Sr. Technical Architect)

	
            org.springframework.boot
            spring-boot-starter-websocket
        
        
            org.webjars
            webjars-locator
        
        
            org.webjars
            sockjs-client
            1.0.2
        
        
            org.webjars
            stomp-websocket
            2.3.3
        
        
            org.webjars
            bootstrap
            3.3.7
        
        
            org.webjars
            jquery
            3.1.0
        
        
            org.springframework.boot
            spring-boot-starter-test
            test
        

public class Message {
    private String name;
    public Message() {
    }
    public Message(String name) {
        this.name = name;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
}

public class Wishing {
    private String content;
    public Wishing() {
    }
    public Wishing(String content) {
        this.content = content;
    }
    public String getContent() {
        return content;
    }
}

@Controller
public class WishingController {
    @MessageMapping("/hey")
    @SendTo("/topic/wishing")
    public Wishing wishing(HelloMessage message) throws Exception {
        Thread.sleep(1000); // simulated delay
        return new Wishing("Hey, " + message.getName() + "!");
    }
}

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/app");
    }
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/gs-websocket").withSockJS();
    }
}

public class User {
	private final Long userId;
	private final String fullName;
	public User() {
		this.userId = -1L;
		this.fullName = "";
	}
	public User(Long userId,String fullName) {
		this.userId = userId;
		this.fullName = fullName;
	}
	public Long getUserId() {
		return userId;
	}
	public String getFullName() {
		return fullName;
	}
}

import java.util.concurrent.atomic.AtomicLong;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import com.kundan.model.User;
@RestController
public class UserController {
    private static final String template = "Hello, %s!";
    private final AtomicLong counter = new AtomicLong();
    @GetMapping("/user")
    public User getUser(@RequestParam(required=false, defaultValue="User") String name) {
        System.out.println("==== in getUser() ====");
        return new User(counter.incrementAndGet(), String.format(template, name));
    }
}

@CrossOrigin(origins = "http://localhost:9200")
@GetMapping("/user")
public User getUser(@RequestParam(required=false, defaultValue="User") String name) {
      System.out.println("==== in getUser() ====");
      return new User(counter.incrementAndGet(), String.format(template, name));
}

String response = restTemplate.getForObject("http://localhost/hotel/{hostelId}/bookings/{booking}", String.class, "12", "22");

Map parameters = new HashMap();
vars.put("hostelId", "12");
vars.put("booking", "22");
String response = restTemplate.getForObject("http://localhost/hotel/{hostelId}/bookings/{booking}", String.class, parameters);

@SpringBootApplication
public class Application {

	private static final Logger log = LoggerFactory.getLogger(Application.class);

	public static void main(String args[]) {
		SpringApplication.run(Application.class);
	}

	@Bean
	public RestTemplate restTemplate(RestTemplateBuilder builder) {
		return builder.build();
	}

	@Bean
	public CommandLineRunner run(RestTemplate restTemplate) throws Exception {
		return args -> {
			User user = restTemplate.getForObject(
					"http://localhost/api/user/{userId}", User.class,1);
			log.info(user.toString());
		};
	}
}

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
@JsonIgnoreProperties(ignoreUnknown = true)
public class User {

    private String firstName;
     private String lastName;

    public User() {
    }

    public String getFirstName() {
        return firstName;
    }

    public void setFirstName(String firstName) {
        this.firstName = firstName;
    }

    public Value getLastName() {
        return lastName;
    }

    public void setValue(String lastName) {
        this.lastName = lastName;
    }

    @Override
    public String toString() {
        return "User{" +
                "firstName='" + firstName + '\'' +
                ", lastName=" + lastName +
                '}';
    }
}

	
            org.springframework.boot
            spring-boot-starter-amqp
        

#Rabbitmq configuration
spring.rabbitmq.host=hostURL
spring.rabbitmq.port = hostPort
spring.rabbitmq.username = username
spring.rabbitmq.password = password
spring.rabbitmq.virtual-host=virtualHost
spring.rabbitmq.ssl.enabled=true
spring.rabbitmq.ssl.algorithm=TLSv1.2
spring.rabbitmq.ssl.key-store=/rabbitmq-security/dev/inno-certs-p12/keycert.p12
spring.rabbitmq.ssl.key-store-password=tihm2k16
spring.rabbitmq.ssl.trust-store=/rabbitmq-security/dev/rabbitstore
spring.rabbitmq.ssl.trust-store-password=truststorepass

	
            org.springframework.boot
            spring-boot-starter-amqp
       

#Rabbitmq configuration
spring.rabbitmq.host=hostUrl
spring.rabbitmq.port = hostPort
spring.rabbitmq.username =username
spring.rabbitmq.password =password
spring.rabbitmq.virtual-host=virtualHost

public class RobbitMqConfig  {
	public final static String publishQName ="publishQueue";
	public final static String consumeQName ="consumeQueue";
	@Bean
	public Jackson2JsonMessageConverter jsonMessageConverter(){
		Jackson2JsonMessageConverter con= new Jackson2JsonMessageConverter();
		return con;
	}
	@Bean
	RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
		RabbitTemplate templete=new RabbitTemplate();
		templete.setExchange("exchange");//Set exchange
		templete.setQueue(publishQName);//Declare queue
		templete.setMessageConverter(jsonMessageConverter());
		templete.setConnectionFactory(connectionFactory);
		return templete;
	}
	@Bean
	SimpleMessageListenerContainer container(ConnectionFactory connectionFactory) {
		SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
		container.setConnectionFactory(connectionFactory);
		container.setQueueNames(consumeQName);
		container.setMessageConverter(jsonMessageConverter());
		container.setMessageListener(consumer());
		return container;
	}
	@Bean MessageListener consumer(){
		return new Consumer();
	}
}

public class RabbitmqTest {
	@Autowired
	private RabbitTemplate rabbitTemplate;
	@Test
	public void test() throws Exception {
		rabbitTemplate.convertAndSend(RobbitMqConfig.publishQName, "RabbitMQ Spring JSON Example");
		System.out.println("Is listener returned ::: "+rabbitTemplate.isReturnListener());
	}
}

@Service
public class Consumer implements MessageListener {
	private final Logger log = LoggerFactory.getLogger(Consumer.class);	
	@Override
	public void onMessage(Message message) {
		String parseMessage=new String(message.getBody());
		log.info("consumer message {}",parseMessage);
	}
}

	com.googlecode.json-simple
	json-simple
	1.1


	org.apache.httpcomponents
	httpclient
	4.3.1

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;

import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.HttpClientBuilder;
import org.json.simple.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class CaptionDataUtil {
	
	private static final Logger log = 
			LoggerFactory.getLogger(CaptionDataUtil.class);

	public static void main(String[] args) throws UnsupportedEncodingException, IOException{
		HttpPost request = createPostReq("http://my.labs.com/api/v1/authenticate");
		JSONObject jsonData = new JSONObject();
		jsonData.put("username", "dddd");
		jsonData.put("password", "xxxxx");
		jsonData.put("stayLoggedIn", false);
		executeHttpPostRequest(jsonData.toString(),request);
	}
	
	private static HttpPost createPostReq(String restUrl) {
		HttpPost request = new HttpPost(restUrl);
		return request;
	}

	
	private static String executeHttpPostRequest(String jsonData,  HttpPost httpPost)  throws UnsupportedEncodingException, IOException {
		HttpResponse response=null;
		String line = "";
		StringBuffer result = new StringBuffer();
		httpPost.setEntity(new StringEntity(jsonData));
		HttpClient client = HttpClientBuilder.create().build();
		response = client.execute(httpPost);
		log.debug("Post parameters : " + jsonData );
		log.debug("Response Code : " +response.getStatusLine().getStatusCode());
		BufferedReader reader = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
		while ((line = reader.readLine()) != null){ result.append(line); }
		log.debug(result.toString());
		return result.toString();
	}
}

  false
  gui
  /home/kundan/oodles-work/CaptionLabsUDP/target/CaptionLabsUDP-1.0.0-SNAPSHOT-jar-with-dependencies.jar
  /home/kundan/Desktop/captionlab.exe
  
  
  .
  normal
  http://java.com/download
  
  false
  false
  
  /home/kundan/Desktop/Smile Face.ico
  
    
    false
    false
    1.7.0
    
    preferJre
    64/32
  

>launch4j.exe your_setting.xml

import javafx.application.Application;
import javafx.event.ActionEvent;
import javafx.event.EventHandler;
import javafx.geometry.Insets;
import javafx.geometry.Pos;
import javafx.scene.Scene;
import javafx.scene.control.Button;
import javafx.scene.control.Label;
import javafx.scene.control.PasswordField;
import javafx.scene.control.TextField;
import javafx.scene.layout.GridPane;
import javafx.scene.layout.HBox;
import javafx.scene.layout.StackPane;
import javafx.scene.paint.Color;
import javafx.scene.text.Font;
import javafx.scene.text.FontWeight;
import javafx.scene.text.Text;
import javafx.stage.Stage;

/**
 *
 * @author kundan
 */
public class JavaFxTest extends Application {
    
    @Override
    public void start(Stage primaryStage) {       
        primaryStage.setTitle("JavaFX Welcome");
        GridPane grid = new GridPane();
        grid.setAlignment(Pos.CENTER);
        grid.setHgap(10);
        grid.setVgap(10);
        grid.setPadding(new Insets(25, 25, 25, 25));
        Text scenetitle = new Text("Welcome");
        scenetitle.setFont(Font.font("Tahoma", FontWeight.NORMAL, 20));
        scenetitle.setId("welcome-text");
        grid.add(scenetitle, 0, 0, 2, 1);

        Label userName = new Label("User Name:");
        userName.setMinSize(80, 50);
        grid.add(userName, 0, 1);

        TextField userTextField = new TextField();
        grid.add(userTextField, 1, 1);

        Label pw = new Label("Password:");
        pw.setMinSize(80, 50);
        grid.add(pw, 0, 2);

        PasswordField pwBox = new PasswordField();
        grid.add(pwBox, 1, 2);
        Button btn = new Button("Sign in");
        HBox hbBtn = new HBox(10);
        hbBtn.setAlignment(Pos.BOTTOM_RIGHT);
        hbBtn.getChildren().add(btn);
        grid.add(hbBtn, 1, 4);
        final Text actiontarget = new Text();
        grid.add(actiontarget, 1, 6);
        btn.setOnAction(new EventHandler() {
 
    @Override
    public void handle(ActionEvent e) {
        actiontarget.setFill(Color.FIREBRICK);
        actiontarget.setText("Sign in button pressed");
    }
    });
        Scene scene = new Scene(grid, 300, 275);
        scene.getStylesheets().add
 (JavaFxTest.class.getResource("Login.css").toExternalForm());
        primaryStage.setScene(scene);
        primaryStage.show();
    }

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        launch(args);
    }
}

.root {
     -fx-background-image: url("background.jpg");
}
.label {
    -fx-font-size: 12px;
    -fx-font-weight: bold;
    -fx-text-fill: #333333;
    -fx-effect: dropshadow( gaussian , rgba(255,255,255,0.5) , 0,0,0,1 );
}
#welcome-text {
   -fx-font-size: 32px;
   -fx-font-family: "Arial Black";
   -fx-fill: #818181;
   -fx-effect: innershadow( three-pass-box , rgba(0,0,0,0.7) , 6, 0.0 , 0 , 2 );
}
#actiontarget {
  -fx-fill: FIREBRICK;
  -fx-font-weight: bold;
  -fx-effect: dropshadow( gaussian , rgba(255,255,255,0.5) , 0,0,0,1 );  
}

import javafx.application.Application;
import javafx.event.ActionEvent;
import javafx.event.EventHandler;
import javafx.scene.Scene;
import javafx.scene.control.Button;
import javafx.scene.layout.StackPane;
import javafx.stage.Stage;
 
public class FirstApp extends Application {
    public static void main(String[] args) {
        launch(args);
    }
    
    @Override
    public void start(Stage primaryStage) {
        primaryStage.setTitle("Hello World!");
        Button btn = new Button();
        btn.setText("Say 'Hello World'");
        btn.setOnAction(new EventHandler() {
 
            @Override
            public void handle(ActionEvent event) {
                System.out.println("Hello World!");
            }
        });
        
        StackPane root = new StackPane();
        root.getChildren().add(btn);
        primaryStage.setScene(new Scene(root, 300, 250));
        primaryStage.show();
    }
}

	
		
			messages
		
	

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * An app that print text from properties file
 *
 */
public class App 
{
    public static void main( String[] args )
    {
    	ApplicationContext context = new ClassPathXmlApplicationContext("Spring-Module.xml");
    	 
        System.out.println(context.getMessage("greeting", null, "Default greetings",null));
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.MessageSource;

/**
 * Injected messageSOurce and print text from properties file
 *
 */
public class MyClass 
{
	private MessageSource messageSource;
	
	public void setMessageSource(MessageSource messageSource) {
		this.messageSource = messageSource;
	}
	
	public void printHello() {
		System.out.println("Hello ! " + messageSource.getMessage("username", null, "Username not found", null));
	}
}

compile 'com.amazonaws:aws-java-sdk:1.9.37'

grails.plugin.awssdk.accessKey='YOUR_AWS_ACCESS_KEY'
grails.plugin.awssdk.secretKey='YOUR_AWS_SECRET_KEY'
gralis.plugin.awssdk.ses.sender='YOUR_SENDER_ADDRESS'

package com.makzy.service
import com.amazonaws.services.simpleemail.model.Body
import com.amazonaws.services.simpleemail.model.Content
import com.amazonaws.services.simpleemail.model.Destination
import com.amazonaws.services.simpleemail.model.Message
import com.amazonaws.services.simpleemail.model.SendEmailRequest
import com.makzy.domain.User

class MailService {
    def grailsApplication

    /** The transactional. */
    static transactional = false

    /** The amazon web service. */
    def amazonWebService

    /** The groovy page renderer. */
    def groovyPageRenderer

    /**
     * Sets the async mail.
     *
     * @param model - domain object
     * @param template - template used for mail
     * @param from - from address
     * @param destination - array of addresses mail is sent to
     * @param subject - mail subject
     * @return the java.lang. object
     */
    public def sendMail(subject, template, model, destination) {

        def from = grailsApplication.config.gralis.plugin.awssdk.ses.sender
        def output = groovyPageRenderer.render view: '/emailtemplates/' + template, model: [data: model]
        Body body = new Body().withHtml(new Content(output.toString()))
        Message message = new Message(new Content(subject), body)
        def result = amazonWebService.ses.sendEmail(new SendEmailRequest(from.toString(), new Destination([destination]), message))
	println result
	return result
    }
}

public class ExceptionHandling
{
	public static void main( String[] args )
	{
   		try {
   			URL newUrl = new URL("http://www.yoursimpledate.server/");
   			BufferedReader reader = new 
				BufferedReader(newInputStreamReader(newUrl.openStream()));
   			String line = reader.readLine();
   			SimpleDateFormat formater = new SimpleDateFormat("MM/DD/YY");
   			Date date = formater.parse(line);
   		}
		// handle passing in the wrong type of URL.
   		catch(ParseException exception) {
			System.out.println(“Passing wrong type of Url::::”+exception);
		}
		// handle I/O problems.
		catch(IOException exception) {
			System.out.println(“IO exception:::::”+exception);
		}
		// handle date parse problems.
		catch(ParseException exception) {
   			System.out.println(“Date parse exception:::”+exception)	;	
		}
	}
}

public class ExceptionHandlingNovice
{
	public static void main( String[] args )
	{
   		try {
   			URL newUrl = new URL("http://www.yoursimpledate.server/");
   			BufferedReader reader = new 
				BufferedReader(new InputStreamReader(newUrl.openStream()));
   			String line = reader.readLine();
   			SimpleDateFormat formater = new SimpleDateFormat("MM/DD/YY");
   			Date date = formater.parse(line);
   		}
	// I am an inexperienced or lazy programmer here.
   		catch(Exception exception) {
			System.out.println(“Exception occured :::”+exception);
   		}
   	}
}

public class ExceptionHandlingNew
{
	public static void main( String[] args )
	{
		try {
   			URL newUrl = new URL("http://www.yoursimpledate.server/");
   			BufferedReader reader = new BufferedReader(
   				new InputStreamReader(url.openStream()));
   			String line = reader.readLine();
   			SimpleDateFormat formater = new SimpleDateFormat("MM/DD/YY");
   			Date date = formater.parse(line);
   		}
	        // handle our problems here.
   		catch(ParseException | IOException exception) {
			System.out.pritnln(“Exception occured ”+exception);
   		}
   	}
}

	org.apache.httpcomponents
	httpclient
	4.3.1

private HttpDelete createDeleteReq(String restUrl,String accessToken)
{
	HttpDelete httpDelete=new HttpDelete(restUrl);
	httpDelete.addHeader(“Authorization”,”OAuth”+" "+accessToken));
	httpDelete.addHeader(“Host”,”your_host_name”);
	httpDelete.addHeader(“User-Agent”,"your_client_name");
	return httpDelete;
}

private String executeDeleteReq(HttpDelete httpDeleteRequest)
{
	HttpClient client = HttpClientBuilder.create().build();
	HttpResponse response=null;
	try {
		response = client.execute(httpDeleteRequest);
	} catch (ClientProtocolException e) {
		e.printStackTrace();
	} catch (IOException e) {
		e.printStackTrace();
	}
	log.debug("Response Code : " + response.getStatusLine().getStatusCode()+"Response status:::"+response.getStatusLine());
	BufferedReader rd=null;
	try {
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
	} catch (IllegalStateException e) {
		e.printStackTrace();
	} catch (IOException e) {
		e.printStackTrace();
	}
	StringBuffer result = new StringBuffer();
	String line = "";
	try {
		while ((line = rd.readLine()) != null) {
			result.append(line);
		}
	} catch (IOException e) {
		e.printStackTrace();
	}
	JSONParser parser=new JSONParser();
	JSONObject jsonResponse=new JSONObject();
	try {
		jsonResponse=(JSONObject)parser.parse(result.toString());
	} catch (ParseException e) {
		e.printStackTrace();
	}
	return jsonResponse.toString();
}

public void testDeleteMethod()
{
	HttpDelete httpDelete =createDeleteReq(restUrl,accessToken);
	String jsonResponse=executeDeleteReq(httpDelete);
	log.debug(“Response for calling Put request:::::::”+jsonResponse);
}

	org.apache.httpcomponents
	httpclient
	4.3.1

private HttpPut createPutReq(String restUrl,String accessToken,String jsonData)
{
	HttpPut httpPut=new HttpPut(restUrl);
	httpPut.addHeader(OAuthFieldName.AUTHORIZATION.toString(),(OAuthFieldName.OAUTH.toString()+" "+ accessToken));
	httpPut.addHeader(OAuthFieldName.HOST.toString(),"your_host”);
	httpPut.addHeader(OAuthFieldName.USER_AGENT.toString(),”your_client”);
	try {
		httpPut.setEntity(new StringEntity(jsonData));
	} catch (UnsupportedEncodingException e) {
		e.printStackTrace();
	}
	return httpPut;
}

private String executePutLightSpeedReq(HttpPut httpPut)
{
	HttpResponse response=null;
	String line = "";
	StringBuffer result = new StringBuffer();
	HttpClient client = HttpClientBuilder.create().build();
	try {
		response = client.execute(httpPut);
	} catch (ClientProtocolException e) {
			e.printStackTrace();
	} catch (IOException e) {
		e.printStackTrace();
	}
	log.debug("Response Code : " +response.getStatusLine().getStatusCode());
	BufferedReader reader=null;
	try {
		reader = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
	} catch (IllegalStateException e) {
		e.printStackTrace();
	} catch (IOException e) {
		e.printStackTrace();
	}
	try {
		while ((line = reader.readLine()) != null){ result.append(line); }
	} catch (IOException e) {
		e.printStackTrace();
	}
	org.json.JSONObject jsonResponse=XML.toJSONObject(result.toString());
	log.debug("jsonResponse ::::"+jsonResponse.toString());
	return jsonResponse.toString();
}

public void testPutMethod()
{
	HttpPut httpPut  =createPutReq(restUrl,accessToken,jsonData);
	String jsonResponse=executePutLightSpeedReq(put);
	log.debug(“Response for calling Put request:::::::”+jsonResponse);
}

	org.apache.oltu.oauth2
		org.apache.oltu.oauth2.client
		1.0.0

import java.io.IOException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.oltu.oauth2.client.request.OAuthClientRequest;
import org.apache.oltu.oauth2.common.exception.OAuthSystemException;
import org.apache.oltu.oauth2.common.message.types.GrantType;
import org.springframework.stereotype.Controller;
import org.springframework.web.servlet.ModelAndView;
@Controller
public class OAuthController 
{
	public ModelAndView handleRequest(HttpServletRequest req, HttpServletResponse response) throws OAuthSystemException, IOException{
		OAuthClientRequest request=null;
		request = OAuthClientRequest
					.authorizationLocation(“your server’s auth location ”)
					.setResponseType(“code”)
					.setState("1")
					.setClientId("your client id")
					.setRedirectURI("http://localhost:8080/Scheduler/auth/kounta/callback.html")
					.buildQueryMessage();
		System.out.println("Url for redirecting::::"+request.getLocationUri());
		return new ModelAndView("redirect:"+request.getLocationUri());
	}
}

import java.io.IOException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.oltu.oauth2.client.OAuthClient;
import org.apache.oltu.oauth2.client.URLConnectionClient;
import org.apache.oltu.oauth2.client.request.OAuthClientRequest;
import org.apache.oltu.oauth2.client.response.OAuthAccessTokenResponse;
import org.apache.oltu.oauth2.client.response.OAuthAuthzResponse;
import org.apache.oltu.oauth2.common.exception.OAuthProblemException;
import org.apache.oltu.oauth2.common.exception.OAuthSystemException;
import org.apache.oltu.oauth2.common.message.types.GrantType;
import org.springframework.stereotype.Controller;
import org.springframework.web.servlet.ModelAndView;
@Controller
public class AuthCallbackController 
{
		public ModelAndView handleRequest(HttpServletRequest request, HttpServletResponse response) 
			throws IOException, OAuthSystemException, OAuthProblemException {
		OAuthAuthzResponse oar = OAuthAuthzResponse.oauthCodeAuthzResponse(request);
		String stateResponse = oar.getState();
		if (stateResponse.equals("")) {
			return new ModelAndView("posIndex","message", "Unsuccessful");
		}
		OAuthClient oAuthClient = new OAuthClient(new URLConnectionClient());
		OAuthAccessTokenResponse oAuthResponse = getAccessToken(oar, oAuthClient);
		System.out.println("Hey I am getting access token::::"+oAuthResponse.getAccessToken());
		return new ModelAndView("posIndex","message", "successful");
	}

	private OAuthAccessTokenResponse getAccessToken(OAuthAuthzResponse oar, OAuthClient oAuthClient)
			throws OAuthSystemException, OAuthProblemException {
		String code = oar.getCode();
		OAuthClientRequest request = OAuthClientRequest
				.tokenLocation("your server’s token location")
				.setGrantType(GrantType.AUTHORIZATION_CODE)
				.setClientId("your client id")
				.setClientSecret("your client secret")
				.setCode(code)
				.setRedirectURI("http://localhost:8080/Scheduler/auth/kounta/callback.html")
				.buildBodyMessage();
		OAuthAccessTokenResponse oAuthResponse = oAuthClient.accessToken(request);
		return oAuthResponse; 
	}
}

		
oAuthController
			authCallbackController

	org.apache.oltu.oauth2
		org.apache.oltu.oauth2.client
		1.0.0

public void OauthMethod(String authLocation,String clientId,String clientSecret,String redirectUri,String tokenLocation)
{
	String accessToken="";
	OAuthClientRequest outhReq=null;
	try {
		outhReq = OAuthClientRequest
			.authorizationLocation(authLocation)
			.setResponseType("code")
			.setState("1")
			.setClientId(clientId)
			.setRedirectURI(redirectUri)
			.buildQueryMessage();
	} catch (OAuthSystemException e) {
		e.printStackTrace();
	}
	//in web application you make redirection to uri:
	log.debug("Visit: " + request.getLocationUri() + "\nand grant permission");
	log.debug("Now enter the OAuth code you have received in redirect uri ");
	OAuthClient oAuthClient = new OAuthClient(new URLConnectionClient());
	BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
	String tempCode="";
	try {
		tempCode = br.readLine().trim();
	} catch (IOException e) {
		e.printStackTrace();
	}
	try {
		outhReq = OAuthClientRequest
			.tokenLocation(tokenLocation)
			.setGrantType(GrantType.AUTHORIZATION_CODE)
			.setClientId(clientId)
			.setClientSecret(clientSecret)
			.setCode(code)
			.setRedirectURI(redirectUri)
			.buildBodyMessage();
	} catch (OAuthSystemException e) {
		e.printStackTrace();
	}
	OAuthAccessTokenResponse oAuthResponse=null;
	try {
		oAuthResponse = oAuthClient.accessToken(outhReq);
	} catch (OAuthSystemException e) {
		e.printStackTrace();
	} catch (OAuthProblemException e) {
		e.printStackTrace();
	}
	token=oAuthResponse.getAccessToken();
	log.debug("Access Token:"+accessToken);
	log.debug("Expires in: "+oAuthResponse.getExpiresIn()+",Refresh token:"+oAuthResponse.getRefreshToken());
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.nio.charset.Charset;
import org.apache.commons.codec.binary.Base64;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.HttpClientBuilder;

public class HttpGetReq
{
	public static void main(String args[]) throws UnsupportedEncodingException
	{
		//Rest URL for showing specific beacon detail
		String restUrl="http://api.kontakt.io/beacon/"+beaconId;
		String username=yourkontaktusername;
		String password=kontaktpassword;
		HttpGetReq httpPostReq=new HttpGetReq();
		HttpGet httpPost=httpPostReq.createConnectivity(restUrl , username, password);
		httpPostReq.executeReq( httpPost);
	}

	HttpGet createConnectivity(String restUrl, String username, String password)
	{
		HttpGet get = new HttpGet(restUrl);
		String auth=new StringBuffer(username).append(":").append(password).toString();
		byte[] encodedAuth = Base64.encodeBase64(auth.getBytes(Charset.forName("US-ASCII")));
		String authHeader = "Basic " + new String(encodedAuth);
		get.setHeader("Content-Type", "application/json");
		get.setHeader("Api-Key","TXBbxWrOVZfFtffLpmhubuGTdnbnmFGl");
		get.setHeader("Accept", "application/json");
		get.setHeader("AUTHORIZATION", authHeader);
		return get;
	}

	void executeReq( HttpGet httpPost)
	{
		try{
			executeHttpGetRequest( httpPost);
		}
		catch (UnsupportedEncodingException e){
			System.out.println("error while encoding api url : "+e);
		}
		catch (IOException e){
			System.out.println("ioException occured while sending http request : "+e);
		}
		catch(Exception e){
			System.out.println("exception occured while sending http request : "+e);
		}
		finally{
			httpPost.releaseConnection();
		}
	}

	void executeHttpGetRequest( HttpGet httpPost)  throws UnsupportedEncodingException, IOException
	{
		HttpResponse response=null;
		String line = "";
		StringBuffer result = new StringBuffer();
		HttpClient client = HttpClientBuilder.create().build();
		response = client.execute(httpPost);
		System.out.println("Response Code : " +response.getStatusLine().getStatusCode());
		BufferedReader reader = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
		while ((line = reader.readLine()) != null){ result.append(line); }
		System.out.println(result.toString());
	}
}

{"id":"9abf0349-b988-45e5-8ef1-11aeb2dbda31","serial":null,"alias":null,"proximity":"f7826da6-4fa2-4e98-8024-bc5b71e0893e","major":64284,"minor":5797,"password":"6LHV","uniqueId":"ZYWX","txPower":3,"interval":350,"name":"Kontakt","venue":{"id":"114135fb-783a-4072-828d-ed2b87e9d7f1","name":"oodles technologies","description":"FF307E Gurgaon","lat":null,"lng":null,"priv":true,"coverType":"image/jpeg","beacons":[],"users":[],"rates":[],"managers":[],"beaconsCount":1},"browserActions":[],"contentActions":[{"actionType":"CONTENT","id":"4bf2f932-9822-49b5-be36-093779c0c77c","actionType":"CONTENT","distance":null,"proximity":"IMMEDIATE","beacon":null,"owner":{"id":"f746c7f3-aa6a-42ca-ba1d-05a2f8908299","email":null,"password":null,"salt":null,"company":null,"venues":null,"active":false},"contentCategory":"IMAGE","contentType":"image/jpeg","contentLength":7761,"impairmentTypes":[]}],"urlRequestActions":[],"actionsCount":1}

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.3.3</version>
</dependency>

URL-https://manager.gimbal.com/api/beacons
Request Type-POST
JDON DATA
    {
        "factory_id":"aaaa-bbbbb",
        "name":"Jony's Beacon",
        "latitude":XX.XXXXXX,
        "longitude":YY.YYYYYY,
        "config_id":wxyz,
        "visibility": "private"
    }

$ wget http://download.redis.io/releases/redis-2.8.9.tar.gz
$ tar xzf redis-2.8.9.tar.gz
$ cd redis-2.8.9
$ make

$ src/redis-server

$ src/redis-cli
redis> set foo bar
OK
redis> get foo
"bar"

sudo mkdir /etc/redis
sudo mkdir /var/redis

	sudo cp utils/redis_init_script /etc/init.d/redis_6379

sudo vi /etc/init.d/redis_6379

sudo cp redis.conf /etc/redis/6379.conf

sudo mkdir /var/redis/6379

Set daemonize to yes (by default it is set to no).
Set the pidfile to /var/run/redis_6379.pid (modify the port if needed).
Change the port accordingly. In our example it is not needed as the default port is already 6379.
Set your preferred loglevel.
Set the logfile to /var/log/redis_6379.log
Set the dir to /var/redis/6379 (very important step!)
Finally add the new Redis init script to all the default runlevels using the following command:
sudo update-rc.d redis_6379 defaults

/etc/init.d/redis_6379 start 

/etc/init.d/redis_6379 start

Start Redis built-in client:-

redis-cli
127.0.0.1:6379>ping
PONG (working correctly)

127.0.0.1:6379> subscribe message 
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "message"
3) (integer) 1

	redis-cli
127.0.0.1:6379> publish message "how are u all"
(integer) 1
On the first tab you can see the message that is published
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "message"
3) (integer) 1
1) "message"
2) "message"
3) "how are u all"

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.4.2</version>
</dependency>

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
public class RedisPubSub
{
    public static final String channel_name= "redisChannel";
    
    public static void main(String[] args) throws Exception
    {       
        JedisPool jedispool = new JedisPool("localhost");
        final Jedis subscriberJedis = jedispool.getResource();

        final Subscriber subscriber = new Subscriber();
        new Thread(new Runnable(){
            public void run()
            {
                try
                {
                    System.out.println("Subscribing to " +channel_name);
                    subscriberJedis.subscribe(subscriber,channel_name);
                    System.out.println("Subscription ended.");
                }
                catch (Exception e)
                {
                    System.out.println("Subscribing failed."+e);
                }
            }
        }).start();

        Jedis publisherJedis = jedispool.getResource();
        new Publisher(publisherJedis,channel_name).start();
        subscriber.unsubscribe();
        jedispool.returnResource(subscriberJedis);
        jedispool.returnResource(publisherJedis);
    }
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import redis.clients.jedis.Jedis;
public class Publisher
{
    private final Jedis publisherJedis ;
    private final String channel_name;
 
    public Publisher(Jedis publisherJedis, String channel)
    {
           this.publisherJedis = publisherJedis;
            this.channel_name = channel;
    }
    public void start()
    {
    	System.out.println("Type your message....exit for terminate");
    	try 
	  {
        	BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
 
             while (true) 
             {
                  String line = reader.readLine();
                  if (!"exit".equals(line)) {
                     publisherJedis.publish(channel_name, line);
                    } 
		    else {
                            break;
                      }
            	}
     	}
 	catch (IOException e) {
                System.out.println("IO failure while reading input, e");
        }
    }
}

import redis.clients.jedis.JedisPubSub;
public class Subscriber extends JedisPubSub {
	@Override
	public void onMessage(String channel, String message) 
	{
        	System.out.println("Message received from channel: "+channel+ " Msg: " + message);
 	}
	@Override
        public void onPMessage(String pattern, String channel, String message) {
        }
	@Override
        public void onSubscribe(String channel, int subscribedChannels) {
	}
	@Override
        public void onUnsubscribe(String channel, int subscribedChannels) {
	}
	@Override
        public void onPUnsubscribe(String pattern, int subscribedChannels) {
	}
	@Override
        public void onPSubscribe(String pattern, int subscribedChannels) {
	}
     }

When you run the RedisPubSub the output will be look like this:

When you run the RedisPubSub the output will be look like this:
Type your message....exit for terminate
Subscribing to redisChannel
hello!!
Message received from channel: redisChannel Msg: hello!!

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>amqp-client</artifactId>
  <version>3.3.1</version>
</dependency>

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
public class Sender {
	private final static String queue_name = "myQueue";
	public static void main(String[] argv) throws Exception {
	      ConnectionFactory factory = new ConnectionFactory();
	      factory.setHost("localhost");
	      Connection con = factory.newConnection();
	      Channel rabbitChannel = con.createChannel();
          rabbitChannel.queueDeclare(queue_name, false, false, false, null);
	      for(int i=0;i<10;i++)
	      {
	      	String msg = "Hello !! This is Oodles Tech. Pvt. Ltd ";
	      	rabbitChannel.basicPublish("",queue_name, null, msg.getBytes());
	      	System.out.println(" ….Sent '" + msg + "'");
	      	Thread.sleep(1000);
	    }
	    rabbitChannel.close();
	    con.close();
	  }
}

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.QueueingConsumer;
public class Receiver {
    private final static String queue_name = "myQueue";
    public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    Connection con = factory.newConnection();
    Channel rabbitChannel = con.createChannel();
    rabbitChannel.queueDeclare(queue_name, false, false, false, null);
    System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
    QueueingConsumer rabbitConsumer = new QueueingConsumer(rabbitChannel);
    rabbitChannel.basicConsume(queue_name, true,rabbitConsumer);
    while (true) {
        QueueingConsumer.Delivery delivery = rabbitConsumer.nextDelivery();
        String msg = new String(delivery.getBody());
        System.out.println(" …. Received '" + msg + "'");
    }
  }
}

….Sent 'Hello !! This is Oodles Tech. Pvt. Ltd '
….Sent 'Hello !! This is Oodles Tech. Pvt. Ltd '
….Sent 'Hello !! This is Oodles Tech. Pvt. Ltd '
….Sent 'Hello !! This is Oodles Tech. Pvt. Ltd '
….Sent 'Hello !! This is Oodles Tech. Pvt. Ltd '

[*] Waiting for messages. To exit press CTRL+C
…. Received 'Hello !! This is Oodles Tech. Pvt. Ltd '
…. Received 'Hello !! This is Oodles Tech. Pvt. Ltd '
…. Received 'Hello !! This is Oodles Tech. Pvt. Ltd '
…. Received 'Hello !! This is Oodles Tech. Pvt. Ltd '
…. Received 'Hello !! This is Oodles Tech. Pvt. Ltd '