Skip to content

Commit

Permalink
Remove useless java-docs
Browse files Browse the repository at this point in the history
  • Loading branch information
@Kirill380
Kirill380 committed Jul 11, 2016
1 parent b9f1108 commit 6064e31
Show file tree
Hide file tree
Showing 10 changed files with 112 additions and 318 deletions.
178 changes: 62 additions & 116 deletions ...ain/java/org/kaaproject/kaa/common/channels/protocols/kaatcp/messages/MessageFactory.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,19 +29,17 @@
/**
* MessageFactory Class. Used to transform byte stream to specific protocol
* messages. Typical use:
*
* <p>
* MessageFactory factory = new MessageFactory();
* factory.registerMessageListener(listener);
* factory.getFramer().pushBytes(bytes);
*
* <p>
* Where listener instance of class which implements one of protocol message
* listeners. and bytes - byte[] stream received from TCP/IP.
*
* @author Andrey Panasenko
*
* @author Andrey Panasenko
*/
public class MessageFactory implements MqttFramelistener {

private Framer framer;
private ConnAckListener connAckListener;
private ConnectListener connectListener;
Expand All @@ -51,20 +49,13 @@ public class MessageFactory implements MqttFramelistener {
private SyncRequestListener syncRequestListener;
private SyncResponseListener syncResponseListener;

/**
* Constructor with externally created Framer.
*
* @param framer
* Framer
*/

public MessageFactory(Framer framer) {
this.setFramer(framer);
framer.registerFrameListener(this);
}

/**
* Default Constructor.
*/

public MessageFactory() {
this.setFramer(new Framer());
framer.registerFrameListener(this);
Expand All @@ -81,154 +72,109 @@ public MessageFactory() {
@Override
public void onMqttFrame(MqttFrame frame) {
switch (frame.getMessageType()) {
case CONNACK:
if (connAckListener != null) {
connAckListener.onMessage((ConnAck) frame);
}
break;
case CONNECT:
if (connectListener != null) {
connectListener.onMessage((Connect) frame);
}
break;
case DISCONNECT:
if (disconnectListener != null) {
disconnectListener.onMessage((Disconnect) frame);
}
break;
case KAASYNC:

onKaaSyncMessage((KaaSync) frame);

break;
case PINGREQ:
if (pingRequestListener != null) {
pingRequestListener.onMessage((PingRequest) frame);
}
break;
case PINGRESP:
if (pingResponseListener != null) {
pingResponseListener.onMessage((PingResponse) frame);
}
break;
default:
break;
case CONNACK:
if (connAckListener != null) {
connAckListener.onMessage((ConnAck) frame);
}
break;
case CONNECT:
if (connectListener != null) {
connectListener.onMessage((Connect) frame);
}
break;
case DISCONNECT:
if (disconnectListener != null) {
disconnectListener.onMessage((Disconnect) frame);
}
break;
case KAASYNC:

onKaaSyncMessage((KaaSync) frame);

break;
case PINGREQ:
if (pingRequestListener != null) {
pingRequestListener.onMessage((PingRequest) frame);
}
break;
case PINGRESP:
if (pingResponseListener != null) {
pingResponseListener.onMessage((PingResponse) frame);
}
break;
default:
break;
}

}

/**
* Private message processor in case of Mqtt frame is KaaSync Message Type
*
* @param frame
* KaaSync object
*
* @param frame KaaSync object
*/
private void onKaaSyncMessage(KaaSync frame) {
KaaSyncMessageType type = frame.getKaaSyncMessageType();
switch (type) {
case SYNC:
if (frame.isRequest()) {
if (syncRequestListener != null) {
syncRequestListener.onMessage((SyncRequest) frame);
case SYNC:
if (frame.isRequest()) {
if (syncRequestListener != null) {
syncRequestListener.onMessage((SyncRequest) frame);
}
} else {
if (syncResponseListener != null) {
syncResponseListener.onMessage((SyncResponse) frame);
}
}
} else {
if (syncResponseListener != null) {
syncResponseListener.onMessage((SyncResponse) frame);
}
}
break;
case UNUSED:
break;
default:
break;
break;
case UNUSED:
break;
default:
break;
}
}

/**
* Register ConnAck message listener.
*
* @param listener
* ConnAckListener
*/

public void registerMessageListener(ConnAckListener listener) {
connAckListener = listener;
}

/**
* Register Connect message listener.
*
* @param listener
* ConnectListener
*/

public void registerMessageListener(ConnectListener listener) {
connectListener = listener;
}

/**
* Register Disconnect message listener.
*
* @param listener
* DisconnectListener
*/

public void registerMessageListener(DisconnectListener listener) {
disconnectListener = listener;
}

/**
* Register PingRequest message listener.
*
* @param listener
* PingRequestListener
*/

public void registerMessageListener(PingRequestListener listener) {
pingRequestListener = listener;
}

/**
* Register PingResponse message listener.
*
* @param listener
* PingResponseListener
*/

public void registerMessageListener(PingResponseListener listener) {
pingResponseListener = listener;
}

/**
* Register SyncRequest message listener.
*
* @param syncRequestListener
* SyncRequestListener
*/

public void registerMessageListener(SyncRequestListener syncRequestListener) {
this.syncRequestListener = syncRequestListener;
}

/**
* Register SyncResponse message listener.
*
* @param syncResponseListener
* SyncResponseListener
*/

public void registerMessageListener(SyncResponseListener syncResponseListener) {
this.syncResponseListener = syncResponseListener;
}

/**
* Framer getter.
*
* @return Framer
*/

public Framer getFramer() {
return framer;
}

/**
* Framer setter.
*
* @param framer
* Framer
*/

public void setFramer(Framer framer) {
this.framer = framer;
}
Expand Down
30 changes: 7 additions & 23 deletions ...src/main/java/org/kaaproject/kaa/common/channels/protocols/kaatcp/messages/MqttFrame.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -56,31 +56,23 @@ protected enum FrameParsingState {
protected int multiplier = 1;
protected FrameParsingState currentState = FrameParsingState.NONE;

/**
* @return the messageType
*/

public MessageType getMessageType() {
return messageType;
}

/**
* @param messageType the messageType to set
*/

protected void setMessageType(MessageType messageType) {
this.messageType = messageType;
}

/**
*
*/

protected MqttFrame() {

}


/**
* @param old te old
*/

protected MqttFrame(MqttFrame old) {
this.messageType = old.getMessageType();
this.buffer = old.getBuffer();
Expand All @@ -90,10 +82,7 @@ protected MqttFrame(MqttFrame old) {
this.currentState = old.currentState;
}

/**
* Return mqtt Frame.
* @return ByteBuffer mqtt frame
*/

public ByteBuffer getFrame() {
if (buffer == null) {
int remainingLegth = getRemainingLegth();
Expand All @@ -109,9 +98,7 @@ public ByteBuffer getFrame() {
return buffer;
}

/**
* Pack message into mqtt frame
*/

abstract protected void pack();

/**
Expand Down Expand Up @@ -239,10 +226,7 @@ public MqttFrame upgradeFrame() throws KaaTcpProtocolException {
return this;
}

/*
* (non-Javadoc)
* @see java.lang.Object#toString()
*/

@Override
public String toString() {
StringBuilder builder = new StringBuilder();
Expand Down
38 changes: 8 additions & 30 deletions ...tty-server/src/main/java/org/kaaproject/kaa/server/common/server/KaaCommandProcessor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,51 +18,29 @@

public interface KaaCommandProcessor<T, U> {

/**
* @return the commandId
*/
int getCommandId();

/**
* @param commandId the commandId to set
*/

void setCommandId(int commandId);

/**
* @return the syncTime
*/

long getSyncTime();

/**
* @param syncTime the syncTime to set
*/

void setSyncTime(long syncTime);

/**
* Retrieves a response.
* @return response instance.
*/

U getResponse();

/**
* Sets a response.
*
*/

void setResponse(U response);

/**
* @return request instance.
*/

T getRequest();

/**
* Sets a request.
*
*/

void setRequest(T request);

/**
* @return command's name.
*/

String getName();
}

0 comments on commit 6064e31

Please sign in to comment.