Fix for #567 "mailinglist gateway does not recover after database outage".
3 * see AUTHORS for the list of contributors
5 * This program is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation, either version 3 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program. If not, see <http://www.gnu.org/licenses/>.
21 import java.sql.Driver;
22 import java.sql.DriverManager;
23 import java.util.Enumeration;
24 import java.util.Date;
25 import java.util.logging.Level;
26 import org.sonews.config.Config;
27 import org.sonews.daemon.ChannelLineBuffers;
28 import org.sonews.daemon.CommandSelector;
29 import org.sonews.daemon.Connections;
30 import org.sonews.daemon.NNTPDaemon;
31 import org.sonews.feed.FeedManager;
32 import org.sonews.mlgw.MailPoller;
33 import org.sonews.storage.StorageBackendException;
34 import org.sonews.storage.StorageManager;
35 import org.sonews.storage.StorageProvider;
36 import org.sonews.util.Log;
37 import org.sonews.util.Purger;
38 import org.sonews.util.io.Resource;
41 * Startup class of the daemon.
42 * @author Christian Lins
45 public final class Main
52 /** Version information of the sonews daemon */
53 public static final String VERSION = "sonews/1.1.0";
54 public static final Date STARTDATE = new Date();
57 * The main entrypoint.
61 public static void main(String[] args) throws Exception
63 System.out.println(VERSION);
64 Thread.currentThread().setName("Mainthread");
66 // Command line arguments
67 boolean feed = false; // Enable feeding?
68 boolean mlgw = false; // Enable Mailinglist gateway?
71 for(int n = 0; n < args.length; n++)
73 if(args[n].equals("-c") || args[n].equals("-config"))
75 Config.inst().set(Config.LEVEL_CLI, Config.CONFIGFILE, args[++n]);
76 System.out.println("Using config file " + args[n]);
78 else if(args[n].equals("-dumpjdbcdriver"))
80 System.out.println("Available JDBC drivers:");
81 Enumeration<Driver> drvs = DriverManager.getDrivers();
82 while(drvs.hasMoreElements())
84 System.out.println(drvs.nextElement());
88 else if(args[n].equals("-feed"))
92 else if(args[n].equals("-h") || args[n].equals("-help"))
97 else if(args[n].equals("-mlgw"))
101 else if(args[n].equals("-p"))
103 port = Integer.parseInt(args[++n]);
105 else if(args[n].equals("-plugin"))
107 System.out.println("Warning: -plugin-storage is not implemented!");
109 else if(args[n].equals("-plugin-command"))
113 CommandSelector.addCommandHandler(args[++n]);
117 Log.get().warning("Could not load command plugin: " + args[n]);
118 Log.get().log(Level.INFO, "Main.java", ex);
121 else if(args[n].equals("-plugin-storage"))
123 System.out.println("Warning: -plugin-storage is not implemented!");
125 else if(args[n].equals("-v") || args[n].equals("-version"))
127 // Simply return as the version info is already printed above
132 // Try to load the JDBCDatabase;
133 // Do NOT USE BackendConfig or Log classes before this point because they require
134 // a working JDBCDatabase connection.
137 StorageProvider sprov =
138 StorageManager.loadProvider("org.sonews.storage.impl.JDBCDatabaseProvider");
139 StorageManager.enableProvider(sprov);
141 // Make sure some elementary groups are existing
142 if(!StorageManager.current().isGroupExisting("control"))
144 StorageManager.current().addGroup("control", 0);
145 Log.get().info("Group 'control' created.");
148 catch(StorageBackendException ex)
150 ex.printStackTrace();
151 System.err.println("Database initialization failed with " + ex.toString());
152 System.err.println("Make sure you have specified the correct database" +
153 " settings in sonews.conf!");
157 ChannelLineBuffers.allocateDirect();
160 Runtime.getRuntime().addShutdownHook(new ShutdownHook());
162 // Start the listening daemon
165 port = Config.inst().get(Config.PORT, 119);
167 final NNTPDaemon daemon = NNTPDaemon.createInstance(port);
170 // Start Connections purger thread...
171 Connections.getInstance().start();
173 // Start mailinglist gateway...
176 new MailPoller().start();
182 FeedManager.startFeeding();
185 Purger purger = new Purger();
188 // Wait for main thread to exit (setDaemon(false))
192 private static void printArguments()
194 String usage = Resource.getAsString("helpers/usage", true);
195 System.out.println(usage);