|
ActiveMQ example source code file (JobLocation.java)
The ActiveMQ JobLocation.java source code/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activemq.broker.scheduler; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.ArrayList; import java.util.Date; import java.util.List; import org.apache.kahadb.journal.Location; import org.apache.kahadb.util.VariableMarshaller; class JobLocation { private String jobId; private int repeat; private long startTime; private long delay; private long nextTime; private long period; private String cronEntry; private final Location location; public JobLocation(Location location) { this.location = location; } public JobLocation() { this(new Location()); } public void readExternal(DataInput in) throws IOException { this.jobId = in.readUTF(); this.repeat = in.readInt(); this.startTime = in.readLong(); this.delay = in.readLong(); this.nextTime = in.readLong(); this.period = in.readLong(); this.cronEntry=in.readUTF(); this.location.readExternal(in); } public void writeExternal(DataOutput out) throws IOException { out.writeUTF(this.jobId); out.writeInt(this.repeat); out.writeLong(this.startTime); out.writeLong(this.delay); out.writeLong(this.nextTime); out.writeLong(this.period); if (this.cronEntry==null) { this.cronEntry=""; } out.writeUTF(this.cronEntry); this.location.writeExternal(out); } /** * @return the jobId */ public String getJobId() { return this.jobId; } /** * @param jobId * the jobId to set */ public void setJobId(String jobId) { this.jobId = jobId; } /** * @return the repeat */ public int getRepeat() { return this.repeat; } /** * @param repeat * the repeat to set */ public void setRepeat(int repeat) { this.repeat = repeat; } /** * @return the start */ public long getStartTime() { return this.startTime; } /** * @param start * the start to set */ public void setStartTime(long start) { this.startTime = start; } /** * @return the nextTime */ public synchronized long getNextTime() { return this.nextTime; } /** * @param nextTime the nextTime to set */ public synchronized void setNextTime(long nextTime) { this.nextTime = nextTime; } /** * @return the period */ public long getPeriod() { return this.period; } /** * @param period * the period to set */ public void setPeriod(long period) { this.period = period; } /** * @return the cronEntry */ public synchronized String getCronEntry() { return this.cronEntry; } /** * @param cronEntry the cronEntry to set */ public synchronized void setCronEntry(String cronEntry) { this.cronEntry = cronEntry; } public boolean isCron() { return getCronEntry() != null && getCronEntry().length() > 0; } /** * @return the delay */ public long getDelay() { return this.delay; } /** * @param delay the delay to set */ public void setDelay(long delay) { this.delay = delay; } /** * @return the location */ public Location getLocation() { return this.location; } public String toString() { return "Job [id=" + jobId + ", startTime=" + new Date(startTime) + ", delay=" + delay + ", period=" + period + ", repeat=" + repeat + ", nextTime=" + new Date(nextTime) + "]"; } static class JobLocationMarshaller extends VariableMarshaller<List Other ActiveMQ examples (source code examples)Here is a short list of links related to this ActiveMQ JobLocation.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.