balvinder294

<!-- Spring Socket Dependencies for Web Sockets -->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.security</groupId>
  <artifactId>spring-security-messaging</artifactId>
</dependency>

balvinder294

package com.tekraze.kafka.config;
import com.tekraze.kafka.security.AuthoritiesConstants;
import java.security.Principal;
import java.util.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.server.*;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.security.authentication.AnonymousAuthenticationToken;
import org.springframework.security.core.authority.SimpleGrantedAuthority;

balvinder294

package com.tekraze.kafka.config;

import com.tekraze.kafka.security.AuthoritiesConstants;

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.SimpMessageType;
import org.springframework.security.config.annotation.web.messaging.MessageSecurityMetadataSourceRegistry;
import org.springframework.security.config.annotation.web.socket.AbstractSecurityWebSocketMessageBrokerConfigurer;

@Configuration

balvinder294

package com.tekraze.kafka.web.websocket;

import static com.tekraze.kafka.config.WebsocketConfiguration.IP_ADDRESS;
import com.tekraze.kafka.web.websocket.dto.ActivityDTO;
import java.security.Principal;

import java.time.Instant;
import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

balvinder294

package com.tekraze.kafka.web.websocket.dto;

import java.time.Instant;

/**
* DTO for storing a user's activity.
*/
public class ActivityDTO {

  private String sessionId;

balvinder294

import { Component, OnInit, OnDestroy } from '@angular/core';

import { JhiTrackerService } from 'app/core';

@Component({
  selector: 'jhi-tracker',
  templateUrl: './tracker.component.html'
})
export class JhiTrackerComponent implements OnInit, OnDestroy {

balvinder294

<div>
  <h2 id="tracker-page-heading">Real-time user activities</h2>
  <div class="table-responsive">
    <table class="table table-striped">
      <thead>
        <tr>
          <th>User</th>
          <th>IP Address</th>
          <th>Current page</th>
          <th>Time</th>

balvinder294

//Imports for packages used
import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration;
import com.amazonaws.services.textract.AmazonTextract;
import com.amazonaws.services.textract.AmazonTextractClientBuilder;
import com.amazonaws.services.textract.model.AnalyzeDocumentRequest;
import com.amazonaws.services.textract.model.AnalyzeDocumentResult;
import com.amazonaws.services.textract.model.Document;
import com.amazonaws.services.textract.model.S3Object;

balvinder294

      
    public Map<String, String> getKeyValueRelationShipByBlocks(List<Block> blocks) {
        Map<String, Map<String, Block>> keyValueBlockMap = getKeyValueBlockMap(blocks);
        getKeyValueRelationShip(keyValueBlockMap);
        return null;
    }

    Block findValueBlock(Block keyBlock, Map<String, Block> valueMap) {
        log.debug("Find value Block ");
        Block valueBlock = null;

balvinder294

/********** Step 1 **********************
*********** File Imports ***************/
import com.amazonaws.services.transcribe.AmazonTranscribe;
import com.amazonaws.services.transcribe.AmazonTranscribeClientBuilder;
import com.amazonaws.services.transcribe.model.DeleteTranscriptionJobRequest;
import com.amazonaws.services.transcribe.model.GetTranscriptionJobRequest;
import com.amazonaws.services.transcribe.model.GetTranscriptionJobResult;
import com.amazonaws.services.transcribe.model.LanguageCode;
import com.amazonaws.services.transcribe.model.Media;
import com.amazonaws.services.transcribe.model.StartTranscriptionJobRequest;