Revision 15:cfc726c09e70

View differences:

src/main/java/cz/agents/alite/protobuf/factory/ProtobufFactory.java
213 213
		
214 214
		try{
215 215
			
216
			//wait for header 
217
			while(input.available()<headerSize){
216
			//check if header available 
217
			if(input.available()<headerSize){
218 218
				LOGGER.info("Waiting for header message of size :"+headerSize + " - available: " + input.available());
219
				try {	
220
					Thread.sleep(3000);
221
				} catch (InterruptedException e) {
222
					e.printStackTrace();
223
				}
219
				return;
224 220
			}
225 221

  
226 222
			//read header

Also available in: Unified diff