← Back to branch summary

~elambert/gearmanij/gearman_java_library

« back to all changes in this revision

Viewing changes to src/org/gearman/client/GearmanClientImpl.java

  • Committer: Eric Lambert
  • Date: 2009-07-08 17:44:39 UTC
  • Revision ID: eric.d.lambert@gmail.com-20090708174439-sg3xb0edz5q65ilx
removed session.sendRequestToServer

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/org/gearman/client/GearmanClientImpl.java
360
360
        return numJobs;
361
361
    }
362
362
 
363
 
        public void handleGearmanJobEvent(GearmanPacket event)
364
 
                throws IllegalArgumentException {
365
 
            if (event == null) {
366
 
                throw new IllegalArgumentException("event can not be null");
367
 
            }
 
363
    public void handleGearmanJobEvent(GearmanPacket event)
 
364
            throws IllegalArgumentException {
 
365
        if (event == null) {
 
366
            throw new IllegalArgumentException("event can not be null");
 
367
        }
368
368
 
369
 
            PacketType type = event.getPacketType();
370
 
            switch (type) {
371
 
                case JOB_CREATED:
372
 
                    updatedJobs.add(event);
373
 
                    break;
374
 
                case WORK_STATUS:
375
 
                    updatedJobs.add(event);
376
 
                    break;
377
 
                case WORK_DATA:
378
 
                    updatedJobs.add(event);
379
 
                    break;
380
 
                case WORK_WARNING:
381
 
                    updatedJobs.add(event);
382
 
                    break;
383
 
                case WORK_COMPLETE:
384
 
                    updatedJobs.add(event);
385
 
                    break;
386
 
                case WORK_FAIL:
387
 
                    updatedJobs.add(event);
388
 
                    break;
389
 
                case WORK_EXCEPTION:
390
 
                    updatedJobs.add(event);
391
 
                    break;
392
 
                default:
393
 
                    LOG.log(Level.WARNING, "Client " + this + " received an " +
394
 
                            "un-recognized job event that it can not handle: " +
395
 
                            event);
396
 
            }
 
369
        PacketType type = event.getPacketType();
 
370
        switch (type) {
 
371
            case JOB_CREATED:
 
372
                updatedJobs.add(event);
 
373
                break;
 
374
            case WORK_STATUS:
 
375
                updatedJobs.add(event);
 
376
                break;
 
377
            case WORK_DATA:
 
378
                updatedJobs.add(event);
 
379
                break;
 
380
            case WORK_WARNING:
 
381
                updatedJobs.add(event);
 
382
                break;
 
383
            case WORK_COMPLETE:
 
384
                updatedJobs.add(event);
 
385
                break;
 
386
            case WORK_FAIL:
 
387
                updatedJobs.add(event);
 
388
                break;
 
389
            case WORK_EXCEPTION:
 
390
                updatedJobs.add(event);
 
391
                break;
 
392
            default:
 
393
                LOG.log(Level.WARNING, "Client " + this + " received an " +
 
394
                        "un-recognized job event that it can not handle: " +
 
395
                        event);
 
396
        }
397
397
 
398
398
    }
399
399