WebSocket - odpowiedz zwrotna

{  
   "id":"OUTDOOR1",
   "label":"Arduino mini pro",
   "type":"INDOOR",
   "lastSeen":"2019-04-27T22:07:11.566Z",
   "internalIP":null,
   "modules":[  
      {  
         "type":"switch",
         "id":4,
         "internalId":0,
         "label":"Pokój Marcina: światło",
         "isOn":false
      },
      {  
         "type":"switch",
         "id":5,
         "internalId":1,
         "label":"Pokój Marcina: lampka",
         "isOn":true
      },
      {  
         "type":"temperatureSensor",
         "id":6,
         "internalId":1,
         "label":"Termometr_1",
         "temperature":34.22
      },
      {  
         "type":"humiditySensor",
         "id":7,
         "internalId":2,
         "label":"Wilgotoność pow.",
         "humidity":55.0
      },
      {  
         "type":"switchDim",
         "id":8,
         "internalId":1,
         "label":"Pokój Marcina: lampka",
         "isOn":true,
         "dim":50
      }
   ]
}

    @MessageMapping("/microcontroller")
    public void handleReading(Microcontroller inbound) {
        Optional<Microcontroller> found = microcontrollerRepository.findById(inbound.getId());

        if (!found.isPresent()) {
            inbound.getModules().forEach(m -> moduleRepository.save(m));
            inbound.setLastSeen(Instant.now());
            Microcontroller saved = microcontrollerRepository.save(inbound);
            log.info("Microcontroller has been saved: " + saved.toString());
        } else {
            List<Module> modules = found.get().getModules();
            List<Module> incomingModules = inbound.getModules();
            if (incomingModules.size() > modules.size()) {
                throw new MoreModulesThanExpectedException(incomingModules.size(), modules.size());
            }
            modules.forEach(m -> moduleRepository.save(m.update(incomingModules.stream()
                            .filter(i -> i.getInternalId().equals(m.getInternalId())).findFirst().get()
                    )
            ));
            found.get().setLastSeen(Instant.now());
            Microcontroller saved = microcontrollerRepository.save(found.get());
            log.info("Microcontroller has been updated: " + saved.toString());

        }
    }

@Order(Ordered.HIGHEST_PRECEDENCE + 99)
public class WebSocketAuthenticationSecurityConfig extends AbstractSecurityWebSocketMessageBrokerConfigurer {
    @Autowired
    private AuthChannelInterceptorAdapter authChannelInterceptorAdapter;

    @Override
    public void registerStompEndpoints(final StompEndpointRegistry registry) {
        // Endpoints are already registered on WebSocketConfig, no need to add more.
    }
    @Override
    protected void customizeClientInboundChannel(ChannelRegistration registration) {
        registration.interceptors(authChannelInterceptorAdapter);
    }

    @Override
    protected void configureInbound(MessageSecurityMetadataSourceRegistry message) {
        message
                .nullDestMatcher().permitAll()
                .simpTypeMatchers(MESSAGE, SUBSCRIBE)
                .authenticated();
    }
    @Override
    protected boolean sameOriginDisabled() {
        return true;
    }
}

@Service
public class AuthChannelInterceptorAdapter implements ChannelInterceptor {

    private static final String USERNAME_HEADER = "login";
    private static final String PASSWORD_HEADER = "passcode";

    @Autowired
    private UserDetailsService userDetailsService;
    @Autowired
    private AuthenticationManager authenticationManager;

    @Override
    public Message<?> preSend(final Message<?> message, final MessageChannel channel) throws AuthenticationException {
        final StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
        if (StompCommand.CONNECT == accessor.getCommand()) {
            final String username = accessor.getFirstNativeHeader(USERNAME_HEADER);
            final String password = accessor.getFirstNativeHeader(PASSWORD_HEADER);

            UserDetails userDetails = userDetailsService.loadUserByUsername(username);
            UsernamePasswordAuthenticationToken user = new UsernamePasswordAuthenticationToken(userDetails, password, userDetails.getAuthorities());
            accessor.setUser(user);
        }
        return message;
    }
...
}