- rename package
This commit is contained in:
parent
bf683be215
commit
23b6297e11
@ -4,19 +4,19 @@ import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
import org.bigbluebutton.red5.api.IBigBlueButtonInGW;
|
||||
import org.bigbluebutton.red5.service.messaging.CreateMeetingMessage;
|
||||
import org.bigbluebutton.red5.service.messaging.DestroyMeetingMessage;
|
||||
import org.bigbluebutton.red5.service.messaging.EndMeetingMessage;
|
||||
import org.bigbluebutton.red5.service.messaging.GetAllMeetingsRequest;
|
||||
import org.bigbluebutton.red5.service.messaging.IMessage;
|
||||
import org.bigbluebutton.red5.service.messaging.KeepAliveMessage;
|
||||
import org.bigbluebutton.red5.service.messaging.MessageFromJsonConverter;
|
||||
import org.bigbluebutton.red5.service.messaging.MessagingConstants;
|
||||
import org.bigbluebutton.red5.service.messaging.RegisterUserMessage;
|
||||
import org.bigbluebutton.red5.service.messaging.UserConnectedToGlobalAudio;
|
||||
import org.bigbluebutton.red5.service.messaging.UserDisconnectedFromGlobalAudio;
|
||||
import org.bigbluebutton.red5.service.messaging.ValidateAuthTokenMessage;
|
||||
import org.bigbluebutton.red5.service.messaging.redis.MessageHandler;
|
||||
import org.bigbluebutton.red5.pubsub.messages.CreateMeetingMessage;
|
||||
import org.bigbluebutton.red5.pubsub.messages.DestroyMeetingMessage;
|
||||
import org.bigbluebutton.red5.pubsub.messages.EndMeetingMessage;
|
||||
import org.bigbluebutton.red5.pubsub.messages.GetAllMeetingsRequest;
|
||||
import org.bigbluebutton.red5.pubsub.messages.IMessage;
|
||||
import org.bigbluebutton.red5.pubsub.messages.KeepAliveMessage;
|
||||
import org.bigbluebutton.red5.pubsub.messages.MessageFromJsonConverter;
|
||||
import org.bigbluebutton.red5.pubsub.messages.MessagingConstants;
|
||||
import org.bigbluebutton.red5.pubsub.messages.RegisterUserMessage;
|
||||
import org.bigbluebutton.red5.pubsub.messages.UserConnectedToGlobalAudio;
|
||||
import org.bigbluebutton.red5.pubsub.messages.UserDisconnectedFromGlobalAudio;
|
||||
import org.bigbluebutton.red5.pubsub.messages.ValidateAuthTokenMessage;
|
||||
import org.bigbluebutton.red5.pubsub.redis.MessageHandler;
|
||||
import org.red5.logging.Red5LoggerFactory;
|
||||
import org.slf4j.Logger;
|
||||
|
||||
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class Constants {
|
||||
public static final String NAME = "name";
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class CreateMeetingMessage implements IMessage {
|
||||
public static final String CREATE_MEETING_REQUEST_EVENT = "create_meeting_request";
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class DestroyMeetingMessage implements IMessage {
|
||||
public static final String DESTROY_MEETING_REQUEST_EVENT = "destroy_meeting_request_event";
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class EndMeetingMessage implements IMessage {
|
||||
public static final String END_MEETING_REQUEST_EVENT = "end_meeting_request_event";
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class GetAllMeetingsRequest implements IMessage {
|
||||
public static final String GET_ALL_MEETINGS_REQUEST_EVENT = "get_all_meetings_request";
|
@ -0,0 +1,5 @@
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public interface IMessage {
|
||||
|
||||
}
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class KeepAliveMessage implements IMessage {
|
||||
public static final String KEEP_ALIVE_REQUEST = "keep_alive_request";
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
import com.google.gson.JsonObject;
|
||||
import com.google.gson.JsonParser;
|
@ -16,7 +16,7 @@
|
||||
* with BigBlueButton; if not, see <http://www.gnu.org/licenses/>.
|
||||
*
|
||||
*/
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class MessagingConstants {
|
||||
|
@ -16,7 +16,7 @@
|
||||
* with BigBlueButton; if not, see <http://www.gnu.org/licenses/>.
|
||||
*
|
||||
*/
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
import redis.clients.jedis.Jedis;
|
||||
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
import java.util.HashMap;
|
||||
import com.google.gson.JsonObject;
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
import java.util.HashMap;
|
||||
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
import java.util.HashMap;
|
||||
import com.google.gson.JsonObject;
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
package org.bigbluebutton.red5.pubsub.messages;
|
||||
|
||||
public class ValidateAuthTokenMessage implements IMessage {
|
||||
public static final String VALIDATE_AUTH_TOKEN = "validate_auth_token";
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging.redis;
|
||||
package org.bigbluebutton.red5.pubsub.redis;
|
||||
|
||||
import java.util.Set;
|
||||
|
@ -16,7 +16,7 @@
|
||||
* with BigBlueButton; if not, see <http://www.gnu.org/licenses/>.
|
||||
*
|
||||
*/
|
||||
package org.bigbluebutton.red5.service.messaging.redis;
|
||||
package org.bigbluebutton.red5.pubsub.redis;
|
||||
|
||||
public interface MessageHandler {
|
||||
void handleMessage(String pattern, String channel, String message);
|
@ -1,9 +1,9 @@
|
||||
package org.bigbluebutton.red5.service.messaging.redis;
|
||||
package org.bigbluebutton.red5.pubsub.redis;
|
||||
|
||||
import java.util.concurrent.Executor;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
import org.bigbluebutton.red5.service.messaging.MessagingConstants;
|
||||
import org.bigbluebutton.red5.pubsub.messages.MessagingConstants;
|
||||
import org.red5.logging.Red5LoggerFactory;
|
||||
import org.slf4j.Logger;
|
||||
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging.redis;
|
||||
package org.bigbluebutton.red5.pubsub.redis;
|
||||
|
||||
import java.util.concurrent.BlockingQueue;
|
||||
import java.util.concurrent.Executor;
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging.redis;
|
||||
package org.bigbluebutton.red5.pubsub.redis;
|
||||
|
||||
public class MessageToSend {
|
||||
private final String channel;
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging.redis;
|
||||
package org.bigbluebutton.red5.pubsub.redis;
|
||||
|
||||
public class ReceivedMessage {
|
||||
|
@ -1,4 +1,4 @@
|
||||
package org.bigbluebutton.red5.service.messaging.redis;
|
||||
package org.bigbluebutton.red5.pubsub.redis;
|
||||
|
||||
import java.util.concurrent.BlockingQueue;
|
||||
import java.util.concurrent.Executor;
|
@ -7,8 +7,8 @@ import java.util.Map;
|
||||
import java.util.HashMap;
|
||||
|
||||
import org.bigbluebutton.red5.api.IBigBlueButtonInGW;
|
||||
import org.bigbluebutton.red5.service.messaging.MessagingConstants;
|
||||
import org.bigbluebutton.red5.service.messaging.redis.MessageHandler;
|
||||
import org.bigbluebutton.red5.pubsub.messages.MessagingConstants;
|
||||
import org.bigbluebutton.red5.pubsub.redis.MessageHandler;
|
||||
|
||||
public class ChatMessageListener implements MessageHandler{
|
||||
|
||||
|
@ -1,5 +0,0 @@
|
||||
package org.bigbluebutton.red5.service.messaging;
|
||||
|
||||
public interface IMessage {
|
||||
|
||||
}
|
@ -6,8 +6,8 @@ package org.bigbluebutton.red5.service.participants;
|
||||
|
||||
import org.bigbluebutton.red5.BigBlueButtonApplication;
|
||||
import org.bigbluebutton.red5.api.IBigBlueButtonInGW;
|
||||
import org.bigbluebutton.red5.service.messaging.MessagingConstants;
|
||||
import org.bigbluebutton.red5.service.messaging.redis.MessageHandler;
|
||||
import org.bigbluebutton.red5.pubsub.messages.MessagingConstants;
|
||||
import org.bigbluebutton.red5.pubsub.redis.MessageHandler;
|
||||
import org.red5.logging.Red5LoggerFactory;
|
||||
import org.slf4j.Logger;
|
||||
|
||||
|
@ -1,8 +1,8 @@
|
||||
package org.bigbluebutton.red5.service.voice;
|
||||
|
||||
import org.bigbluebutton.red5.api.IBigBlueButtonInGW;
|
||||
import org.bigbluebutton.red5.service.messaging.MessagingConstants;
|
||||
import org.bigbluebutton.red5.service.messaging.redis.MessageHandler;
|
||||
import org.bigbluebutton.red5.pubsub.messages.MessagingConstants;
|
||||
import org.bigbluebutton.red5.pubsub.redis.MessageHandler;
|
||||
|
||||
import com.google.gson.JsonObject;
|
||||
import com.google.gson.JsonParser;
|
||||
|
@ -3,8 +3,8 @@ package org.bigbluebutton.red5.service.whiteboard;
|
||||
|
||||
|
||||
import org.bigbluebutton.red5.api.IBigBlueButtonInGW;
|
||||
import org.bigbluebutton.red5.service.messaging.MessagingConstants;
|
||||
import org.bigbluebutton.red5.service.messaging.redis.MessageHandler;
|
||||
import org.bigbluebutton.red5.pubsub.messages.MessagingConstants;
|
||||
import org.bigbluebutton.red5.pubsub.redis.MessageHandler;
|
||||
|
||||
import com.google.gson.JsonParser;
|
||||
import com.google.gson.JsonObject;
|
||||
|
Loading…
Reference in New Issue
Block a user