ashemez/springkafkamessaging

Spring-Kafka Messaging app for End Point blog series

Spring-Kafka Messaging app for End Point blog series: https://www.endpointdev.com/blog/tags/spring-kafka-series

Example curl commands

activation

curl -H "Content-Type: application/json" -X POST localhost:8080/api/auth/getcode -d '{ "mobile": "01234" }'

login and get access-token

curl -H "Content-Type: application/json" -X POST localhost:8080/api/auth/login -d '{ "mobile": "01234", "activationCode": "309652" }'

send message REST example

curl -H "Content-Type: application/json" -X POST localhost:8080/api/message/send-message -d '{ "accessToken": "5eab27f8-8748-4fdc-a4de-ac782ce17a74", "sendTo": 5, "msg": "test message" }'

Websocket web UI example is now available.

springkafkamessaging's Issues

when checking multiple receive user

Hello. Thank you for your working.
With your working, I have many knowledge about kafka.

When I check multiple receive user and send message, some user can't receive message.
So I suggest some fix code.

`

//in app.js
function loadContacts() {

// add class cbox for getting multiple checked
$("#contactlist").append('<input type="checkbox" id="sendTo" class="cbox" value="' + ...

}

`

`

// modify for multiple checked user
function sendData() {

var cboxs = $('.cbox:checkbox:checked');

if (cboxs != null) {
	var len = cboxs.length;
	for (var i =0; i < len ; i++) {
		
		var cbox = cboxs[i];			
		var sendTo = cbox.value;			
		var data = JSON.stringify({
		  'topic': 'SEND_MESSAGE',
		  'message': {
		    'accessToken': $("#accessToken").val(),
		    'sendTo': sendTo,
		    'msg': $("#messageArea").val(),
		  }
		})
		ws.send(data);	
	}
	
}

}
`